Azure应用功能应用程序＆＃x27; AppName＆＃x27;已关闭

Question

我正在创建一个Azure应用功能，以从事件中心读取并写入另一个事件中心。最初，我只是从活动中心阅读并记录一些消息，这很好。

原始代码

        [FunctionName("EHFunction")]
        public static async Task Run(
            [EventHubTrigger("ehquery", Connection = "EventHubConnectionString")] EventData[] events,
            ILogger log)
        {
            var exceptions = new List<Exception>();

            foreach (EventData eventData in events)
            {
                try
                {
                    // Read event hub event which contains link to a blob with messages. Read messages from the blob storage endpoint.

                    foreach (var blobEntry in blobData)
                    {
                        foreach (var record in blobEntry.Records)
                        {
                            var recordStr = record.ToString();
                            log.LogInformation($"Record: {recordStr}");
                        }
                    }
                }
                catch (Exception e)
                {
                    // We need to keep processing the rest of the batch - capture this exception and continue.
                    // Also, consider capturing details of the message that failed processing so it can be processed again later.
                    log.LogCritical(e.Message);
                    exceptions.Add(e);
                }
            }

这很棒。现在，我更新了代码以将记录写入新事件中心：

        [FunctionName("EHFunction")]
        public static async Task Run(
            [EventHubTrigger("ehquery", Connection = "EventHubConnectionString")] EventData[] events,
            [EventHub("ehquery-output", Connection = "EventHubOutputConnectionAppSetting")] IAsyncCollector<string> outputEvents,
            ILogger log)
        {
            var exceptions = new List<Exception>();

            foreach (EventData eventData in events)
            {
                try
                {
                    // Read event hub event which contains link to a blob with messages. Read messages from the blob storage endpoint.

                    foreach (var blobEntry in blobData)
                    {
                        foreach (var record in blobEntry.Records)
                        {
                            var recordStr = record.ToString();
                            await outputEvents.AddAsync(recordStr);
                        }
                    }
                }
                catch (Exception e)
                {
                    // We need to keep processing the rest of the batch - capture this exception and continue.
                    // Also, consider capturing details of the message that failed processing so it can be processed again later.
                    log.LogCritical(e.Message);
                    exceptions.Add(e);
                }
            }

当我发布此功能时，我在Eventlog.xml文件中看到以下消息，

<EventData>
<Data>Application 'C:\Program Files (x86)\SiteExtensions\Functions\3.7.1\64bit\' started successfully.</Data>
<Data>Process Id: 3776.</Data>
<Data>File Version: 13.1.22054.23. Description: IIS ASP.NET Core Module V2 Request Handler. Commit: 509f6badec2f3162f0e50330cd9107e5624b379b</Data>
</EventData>
</Event>
<EventData>
<Data>Application 'MACHINE/WEBROOT/APPHOST/EHFunction' has shutdown.</Data>
<Data>Process Id: 4624.</Data>
<Data>File Version: 13.1.22054.23. Description: IIS ASP.NET Core Module V2 Request Handler. Commit: 509f6badec2f3162f0e50330cd9107e5624b379b</Data>
</EventData>
</Event>

这是我的local.settings.json for Reference

{
    "IsEncrypted": false,
  "Values": {
    "AzureWebJobsStorage": "UseDevelopmentStorage=true",
    "EventHubConnectionString": "Endpoint=sb://{inputeventhubconnectionstring}",
    "EventHubOutputConnectionAppSetting": "Endpoint=sb://{outputeventhubconnectionstring}",
    "FUNCTIONS_WORKER_RUNTIME": "dotnet"
  }
}

for hose gose中心？我在做什么错？

Answer 1

谢谢@Gengis Khan，为您在评论中提到的为您服务的解决方案。我正在重新发布同样的解决方案，以便其他社区成员可以从中受益。

为什么该功能无法写入事件中心？我在做什么
错误？

要解决上述问题，当用local.settings.json.json中的EventHub部署Azure函数时，我们为EvensHubOutputConnectionAppsetting。应用程序到Azure无法读取local.settings.json我们需要在Portal上的函数中添加新的应用程序设置（通过 configuration-＆gt; new应用程序设置）通过为eventHuboutputConnectionAppSetting提供正确的值，并保存它。

有关更多信息，请参阅此 < < a href =“ https://stackoverflow.com/questions/69486843/azure-function-app-does-not-trigger-by-event-hub”> ，所以线程 对于类似的问题。