Exercice - Créer une fonction Azure pour simuler des données télémétriques

Pour notre exemple, nous utilisons le sourcing d'événements. Créons une fonction qui simule les données télémétriques et les envoie à un hub d’événements. Plus tard, une autre fonction peut écouter cet événement et le traiter et le stocker dans une base de données créée avec Azure Cosmos DB.

Préparer votre environnement

Nous allons définir certaines variables d’environnement pour que les commandes suivantes restent aussi courtes et compréhensibles que possible. Définissez les <value> placeholders, collez et exécutez les commandes suivantes dans votre terminal ou interface de ligne de commande.

RESOURCE_GROUP=<value>
EVENT_HUB_NAMESPACE=<value>
EVENT_HUB_NAME=<value>
EVENT_HUB_AUTHORIZATION_RULE=<value>
COSMOS_DB_ACCOUNT=<value>
STORAGE_ACCOUNT=<value>
FUNCTION_APP=<value>
LOCATION=<value>

Créer les composants requis

L’approvisionnement des ressources sur Azure prend un certain temps. Commençons par la création du composant dès que possible pour éviter les longues attentes ultérieurement.

Créer un groupe de ressources

Il est toujours judicieux de lier toutes les ressources d’une formation, d’une preuve de concept ou d’un prototype dans un groupe de ressources. De cette façon, vous pouvez nettoyer facilement tous les services utilisés avec une seule commande. Pour créer un groupe de ressources à l’emplacement spécifié, exécutez la commande suivante dans votre terminal :

az group create \
    --name $RESOURCE_GROUP \
    --location $LOCATION

Créer et configurer un hub d’événements

Pour le hub d’événements, il est nécessaire de spécifier l’espace de noms qu’il doit écouter. En outre, vous devez configurer la règle d’autorisation sur Listen et Send.

az eventhubs namespace create \
    --resource-group $RESOURCE_GROUP \
    --name $EVENT_HUB_NAMESPACE
az eventhubs eventhub create \
    --resource-group $RESOURCE_GROUP \
    --name $EVENT_HUB_NAME \
    --namespace-name $EVENT_HUB_NAMESPACE \
az eventhubs eventhub authorization-rule create \
    --resource-group $RESOURCE_GROUP \
    --name $EVENT_HUB_AUTHORIZATION_RULE \
    --eventhub-name $EVENT_HUB_NAME \
    --namespace-name $EVENT_HUB_NAMESPACE \
    --rights Listen Send

Générer, configurer et déployer la fonction Azure

Pour rendre cet exemple aussi réaliste que possible, créez une fonction Azure et simulez des données télémétriques. Vous pouvez également lier un appareil IoT à votre fonction Azure, ce qui prend alors des données réelles. Étant donné que cette fonction est la production d’événements, nous allons ajouter un indicateur p ou -p .

az storage account create \
    --resource-group $RESOURCE_GROUP \
    --name $STORAGE_ACCOUNT"p" \
    --sku Standard_LRS
az functionapp create \
    --resource-group $RESOURCE_GROUP \
    --name $FUNCTION_APP"-p"\
    --storage-account $STORAGE_ACCOUNT"p" \
    --consumption-plan-location $LOCATION \
    --runtime java \
    --functions-version 4

Lorsque la az functionapp create commande crée votre application de fonction, elle crée également une ressource Application Insights portant le même nom. Nous utilisons cette ressource ultérieurement pour notre supervision.

Pour récupérer les chaînes de connexion du compte de stockage et du hub d’événements, utilisez les commandes suivantes pour les enregistrer dans les variables d’environnement, puis les afficher avec la echo commande.

AZURE_WEB_JOBS_STORAGE=$( \
    az storage account show-connection-string \
        --resource-group $RESOURCE_GROUP \
        --name $STORAGE_ACCOUNT"p" \
        --query connectionString \
        --output tsv)
echo $AZURE_WEB_JOBS_STORAGE
EVENT_HUB_CONNECTION_STRING=$( \
    az eventhubs eventhub authorization-rule keys list \
        --resource-group $RESOURCE_GROUP \
        --name $EVENT_HUB_AUTHORIZATION_RULE \
        --eventhub-name $EVENT_HUB_NAME \
        --namespace-name $EVENT_HUB_NAMESPACE \
        --query primaryConnectionString \
        --output tsv)
echo $EVENT_HUB_CONNECTION_STRING

Pour stocker les chaînes de connexion dans les paramètres d’application de votre compte De fonction Azure, exécutez la commande suivante dans votre terminal :

az functionapp config appsettings set \
    --resource-group $RESOURCE_GROUP \
    --name $FUNCTION_APP"-p" \
    --settings \
        AzureWebJobsStorage=$AZURE_WEB_JOBS_STORAGE \
        EventHubConnectionString=$EVENT_HUB_CONNECTION_STRING

À présent, votre hub d’événements Azure et votre fonction Azure sont créés et configurés pour fonctionner correctement ensemble.

Ensuite, créez un projet de fonctions locales avec Maven.

mvn archetype:generate --batch-mode \
    -DarchetypeGroupId=com.microsoft.azure \
    -DarchetypeArtifactId=azure-functions-archetype \
    -DappName=$FUNCTION_APP"-p" \
    -DresourceGroup=$RESOURCE_GROUP \
    -DappRegion=$LOCATION \
    -DappServicePlanName=$LOCATION"plan" \
    -DgroupId=com.learn \
    -DartifactId=telemetry-functions-producer

Cette commande génère plusieurs fichiers dans un dossier telemetry-functions-producer :

• Fichier pom.xml de build avec des dépendances Azure prédéfinies.
• Fichier local.settings.json contenant les paramètres d’application pour le déploiement local et les tests manuels.
• Fichier host.json qui active le bundle d’extensions Azure Functions.
• Fichier Function.java qui inclut la fonction de déclencheur HTTP par défaut.
• Quelques fichiers de test que ce module Learn n’utilise pas.

Nous ne touchons pas les fichiers de test dans ce module Learn. N’hésitez donc pas à les supprimer.

cd telemetry-functions-producer
rm -r src/test

Pour l’exécution locale, les paramètres de l’application doivent être récupérés et stockés dans le local.settings.json fichier. Vous pouvez le faire automatiquement en exécutant la fetch-app-settings commande.

func azure functionapp fetch-app-settings $FUNCTION_APP"-p"

Ensuite, ouvrez le Function.java fichier et remplacez le contenu par le code suivant :

package com.learn;

import com.microsoft.azure.functions.annotation.EventHubOutput;
import com.microsoft.azure.functions.annotation.FunctionName;
import com.microsoft.azure.functions.annotation.TimerTrigger;
import com.microsoft.azure.functions.ExecutionContext;
public class Function {

    @FunctionName("generateSensorData")
    @EventHubOutput(
        name = "event",
        eventHubName = "", // blank because the value is included in the connection string
        connection = "EventHubConnectionString")
    public TelemetryItem generateSensorData(
        @TimerTrigger(
            name = "timerInfo",
            schedule = "*/10 * * * * *") // every 10 seconds
            String timerInfo,
        final ExecutionContext context) {
            context.getLogger().info("Java Timer trigger function executed at: " + java.time.LocalDateTime.now());
            double temperature = Math.random() * 100;
            double pressure = Math.random() * 50;
        return new TelemetryItem(temperature, pressure);
    }
}

La fonction generateSensorData simule un capteur qui envoie des relevés de température et de pression au hub d'événements. Un déclencheur exécute la fonction toutes les 10 secondes et une liaison de sortie du hub d'événements transmet la valeur renvoyée au hub d'événements.

Lorsque le hub d'événements reçoit le message, il génère un événement.

Les données utilisées par cette fonction sont stockées à l’aide d’une classe appelée TelemetryItem, que vous devez implémenter. Créez un fichier appelé TelemetryItem.java dans le même emplacement que Function.java et ajoutez le code suivant :

package com.learn;

public class TelemetryItem {

    private String id;
    private double temperature;
    private double pressure;
    private boolean isNormalPressure;
    private status temperatureStatus;
    static enum status {
        COOL,
        WARM,
        HOT
    }

    public TelemetryItem(double temperature, double pressure) {
        this.temperature = temperature;
        this.pressure = pressure;
    }

    public String getId() {
        return id;
    }

    public double getTemperature() {
        return temperature;
    }

    public double getPressure() {
        return pressure;
    }

    @Override
    public String toString() {
        return "TelemetryItem={id=" + id + ",temperature="
            + temperature + ",pressure=" + pressure + "}";
    }

    public boolean isNormalPressure() {
        return isNormalPressure;
    }

    public void setNormalPressure(boolean isNormal) {
        this.isNormalPressure = isNormal;
    }

    public status getTemperatureStatus() {
        return temperatureStatus;
    }

    public void setTemperatureStatus(status temperatureStatus) {
        this.temperatureStatus = temperatureStatus;
    }
}

Exécution locale

Lorsque vous exécutez des fonctions Azure localement, elles sont déjà diffusées partout dans le monde ! En outre, vous pouvez les consulter dans votre portail Azure.

mvn clean package
mvn azure-functions:run

Après quelques messages relatifs à la génération et au démarrage, une sortie semblable à l'exemple suivant s'affiche à chaque exécution des fonctions :

[2021-01-19T16:25:40.005Z] Executing 'Functions.generateSensorData' (Reason='Timer fired at 2021-01-19T17:25:40.0044630+01:00', Id=fcf567a3-03ec-4159-9714-aa4449861b30)
[2021-01-19T16:25:40.011Z] Java Timer trigger function executed at: 2021-01-19T17:25:40.009405
[2021-01-19T16:25:40.013Z] Function "generateSensorData" (Id: fcf567a3-03ec-4159-9714-aa4449861b30) invoked by Java Worker
[2021-01-19T16:25:40.048Z] Executed 'Functions.generateSensorData' (Succeeded, Id=fcf567a3-03ec-4159-9714-aa4449861b30, Duration=43ms)

Déployer sur Azure

Déclenchez le déploiement sur Azure en exécutant la mvn azure-functions:deploy commande et continuez.

mvn azure-functions:deploy