Push Agent en tant qu’abonné

Par défaut, Push Agent peut envoyer des données vers le cloud. Vous pouvez modifier le code de Push Agent pour recevoir des données du cloud.

Fonction de réception des données

La fonction de l'exemple suivant est appelée chaque fois qu'un message est reçu. La fonction traite le message reçu selon la logique définie dans la fonction, puis met à jour la valeur de variable

messageVariable

private Task SubscribeClientMqttMsgPublishReceived(MqttApplicationMessageReceivedEventArgs e)
{
    var message = e.ApplicationMessage.ConvertPayloadToString();
    var messageVariable = Project.Current.GetVariable("Model/Message");
    messageVariable.Value = Newtonsoft.Json.Linq.JObject.Parse(message)["Rows"][0]["Variables"][0]["Value"].ToString();
    return Task.CompletedTask;
}

Paramètre de configuration de l'abonné

L'exemple suivant présente la fonction de réception des données transmise en tant que paramètre de configuration de l'abonné. En plus de la configuration de base de l’éditeur, la méthode de l’abonné est configurée dans la méthode

Start()

public override void Start()
{
    // PushAgent Default configuration

    // Add subscriber
    mqttClientConnector.AddSubscriberAsync("my_custom_subscriber_topic", 1, SubscribeClientMqttMsgPublishReceived);
}



public async void AddSubscriberAsync(string topic, int qosLevel, Func<MqttApplicationMessageReceivedEventArgs, Task> subscribeClientMqttMsgPublishReceived)
{
    mqttClient.ApplicationMessageReceivedAsync += subscribeClientMqttMsgPublishReceived;
    await mqttClient.SubscribeAsync(topic, GetQoSLevel(qosLevel)).ConfigureAwait(false);
}

Push Agent

Fournir une réponse

Vous avez des questions ou des commentaires sur cette documentation ? Veuillez envoyer vos commentaires ici.