代码之家  ›  专栏  ›  技术社区  ›  Randy Minder

如何从Azure函数向事件中心发送消息?

  •  1
  • Randy Minder  · 技术社区  · 7 年前

    我有一个Azure函数,它可以在任何时候将消息放置在IoT中心时启动。我希望函数从消息中提取一些信息,然后将其放置在另一个事件中心。这是我的代码:

    #r "Microsoft.ServiceBus"
    using System;
    using System.Text;
    using Microsoft.ServiceBus.Messaging;
    
    public static void Run(EventData eventData, out string outputEventHubMessage, TraceWriter log)
    {
        // Get some system properties from the SystemProperties dictionary
        var deviceId = eventData.SystemProperties["iothub-connection-device-id"].ToString();
        var messageSource = eventData.SystemProperties["iothub-message-source"].ToString();
        var enqueuedTime = eventData.SystemProperties["iothub-enqueuedtime"].ToString();
        var sequenceNumber = eventData.SystemProperties["SequenceNumber"].ToString();
        var offset = eventData.SystemProperties["Offset"].ToString();
    
        var data = Encoding.UTF8.GetString(eventData.GetBytes());
        var message = string.Format("Message Source: {0}; Enqueued Time: {1}; Sequence Number: {2}; Offset: {3}; DeviceId: {4}; Data: {5}", messageSource, enqueuedTime, sequenceNumber, offset, deviceId, data);
    
        outputEventHubMessage = message;
    
        log.Info($"{message}");
    }
    

    “outputEventHubMessage”定义为一个输出参数,指向我为此目的设置的事件中心。当函数启动时,我收到以下错误:

    2018-04-11T14:23:50.295 [Error] Exception while executing function: Functions.MonitorHub. Microsoft.Azure.WebJobs.Host: Error while handling parameter outputEventHubMessage after function returned:. 
        Microsoft.ServiceBus: Unauthorized access. 'Send' claim(s) are required to perform this operation. Resource: 'sb://iothub-ns-monitorhub-419050-c0a1f3eb71.servicebus.windows.net/monitorhub'. TrackingId:cd503b7c674e4806a64b592bfa3d51f2_G9, SystemTracker:gateway5, Timestamp:4/11/2018 2:23:50 PM.
    

    我不知道这意味着什么,也不知道为什么Azure在我创建输出参数时不会为我设置它

    1 回复  |  直到 7 年前
        1
  •  3
  •   Mikhail Shilkov    7 年前

    您使用的连接字符串似乎没有发送权限。

    要检查这一点,请转到事件中心命名空间-> Settings -&燃气轮机; Shared access policies 确保 Send 根据您使用的策略列出:

    enter image description here