0
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));
}
}
}
はIoTをハブからデータを取得するには、まだ何かが間違っていました。 このデータを簡単に取得することは可能ですか?
「まだ何かが間違っていました」 - >まさに何か。あなたは例外を受け取りますか? "何か"を定義する –
私たちは本当にいくつかのエラーコードを出力する必要があります。 – Jay
@PeterBonsプログラムの開始後の戻りエラー "未処理の例外:System.IO.FileNotFoundExpection:ファイルまたはアセンブリ 'Microsoft.Service.Bus、Version 3.0.0.0、Culture = neutral、PublicKeyToken = XXX'またはその依存関係の1つを読み込めませんでした。 " dllはexeでディレクトリにあります。なにが問題ですか? – ksk