IOT集線器消息處理器

處理在Azure IoT Hub中創建的消息時遇到一些問題。IOT集線器消息處理器

獲取以下錯誤：拋出的異常：Microsoft.ServiceBus.dll中的'Microsoft.ServiceBus.Messaging.Amqp.AmqpException'（「發生AMQP錯誤（condition ='amqp：link：redirect'）。」）

任何人都可以指向正確的方向嗎？

問候，喬納斯

using System; 
using System.Collections.Generic; 
using System.Linq; 
using System.Text; 
using System.Threading.Tasks; 
using Microsoft.ServiceBus.Messaging; 

namespace IOTHubMessageProcessor 
{ 
    class Program 
    { 
     static string connectionString = "HostName=yaddaaaa.azure-devices.net;SharedAccessKeyName=iothubowner;SharedAccessKey=keydataasdss+tacsCxwkWQeUm9sMCc2GHnQkIZHM="; 
     static string iotHubD2cEndpoint = "messages/events"; 
     static EventHubClient eventHubClient; 
     static void Main(string[] args) 
     { 

      Console.WriteLine("Receive messages\n"); 
      eventHubClient = EventHubClient.CreateFromConnectionString(connectionString, iotHubD2cEndpoint); 

      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)); 
      } 
     } 
    } 
}

來源

2016-03-01 Jonas K

您不應該使用Event Hub兼容端點來使用EventHubClient嗎？ – juunas

嗨，你還有這個問題嗎？ – neolursa