einfache Art und Weise Daten von IoT Hub in C# bekommen

Question

ich nach Code von MS Tutorial https://docs.microsoft.com/en-us/azure/iot-hub/iot-hub-csharp-csharp-getstarted und diese

internal class Program 
{ 
private static string connectionString = "HostName=...="; 
private static string d2cEndpoint = "messages/events"; 
private static EventHubClient eventHubClient; 

private static void Main(string[] args) 
{ 
    Console.WriteLine("Receive messages\n"); 
    eventHubClient = EventHubClient. 
     CreateFromConnectionString(
      connectionString, d2cEndpoint); 

    var d2cPartitions = eventHubClient. 
      GetRuntimeInformation().PartitionIds; 

    foreach (string partition in d2cPartitions) 
    { 
     ReceiveMessagesFromDeviceAsync(partition); 
    } 
    Console.ReadLine(); 
} 

private async static Task ReceiveMessagesFromDeviceAsync(
             string partition) 
{ 
    var eventHubReceiver = eventHubClient. 
      GetDefaultConsumerGroup(). 
      CreateReceiver(partition, DateTime.UtcNow); 
    while (true) 
    { 
     EventData eventData = await eventHubReceiver. 
              ReceiveAsync(); 
     if (eventData == null) continue; 

     string data = Encoding.UTF8.GetString(
            eventData.GetBytes()); 
     Console.WriteLine(string.Format(
      "Message received. Partition: {0} Data: '{1}'", 
      partition, data)); 
    } 
} 
} 

zu erhalten Daten von IoT Hub versuchen, aber immer noch etwas falsch war. Es ist möglich, diese Daten auf einfache Weise zu erhalten?

Answer 1

Mit der Version VS2017> = 15.3.1 können Sie ein Azure-Funktionen-Projekt für EventHubTrigger Funktion ohne einen einzigen Zeilencode erstellen. Der folgende Template-Code-Schnipsel zeigt diese Funktion:

using Microsoft.Azure.WebJobs; 
using Microsoft.Azure.WebJobs.Host; 
using Microsoft.Azure.WebJobs.ServiceBus; 

namespace FunctionApp4 
{ 
public static class Function1 
{ 
    [FunctionName("Function1")] 
    public static void Run([EventHubTrigger("myEventHubName", Connection = "myIoTHub")]string myEventHubMessage, TraceWriter log) 
    { 
     log.Info($"C# Event Hub trigger function processed a message: {myEventHubMessage}"); 
    } 
} 

}

und die local.settings.json Datei:

{ 
    "IsEncrypted": false, 
    "Values": { 
    "AzureWebJobsStorage": "DefaultEndpointsProtocol=https;AccountName=...;AccountKey=...", 
    "AzureWebJobsDashboard": "DefaultEndpointsProtocol=https;AccountName=...;AccountKey=...", 
    "myIoTHub": "Endpoint=sb://....servicebus.windows.net/;SharedAccessKeyName=iothubowner;SharedAccessKey=..." 
    } 
} 

Der folgende Bildschirm Code-Schnipsel zeigt eine Konsole Ausgabe der lokalen azur Funktion :