EventHubTrigger с привязкой EventData[] не работает ⇐ C#
-
Anonymous
EventHubTrigger с привязкой EventData[] не работает
У меня такая же проблема, я использую последнюю версию библиотек. Когда я использую string[], он работает, но как только я меняю его на EventData[], он терпит неудачу.
Файл проекта:
net7.0 v4 Exe последняя Program.cs:
с использованием Microsoft.Azure.Functions.Worker; использование Microsoft.Extensions.Hosting; вар хост = новый HostBuilder() .ConfigureFunctionsWorkerDefaults((IFunctionsWorkerApplicationBuilder _) => { }) .Строить(); хост.Выполнить(); Код функции:
с использованием Azure.Messaging.EventHubs; использование Microsoft.Azure.Functions.Worker; использование Microsoft.Extensions.Logging; пространство имен MyFunctionApp { открытый класс EventHubFunction { частный ILogger только для чтения _logger; public EventHubFunction (регистратор ILogger) { _logger = регистратор; } [Функция(имя(EventHubFunction)] public void Run([EventHubTrigger(Constants.EventHub, Connection = Constants.Connection, ConsumerGroup = Constants.ConsumerGroup, IsBatched = true)] EventData[] eventDatas) { foreach (var eventData в eventDatas) { //обработка сообщения } } } } Он никогда не попадает внутрь метода, и я получил следующую ошибку:
System.Private.CoreLib: исключение при выполнении функции: EventHubFunction. Microsoft.Azure.WebJobs.Host: параметр привязки исключения eventDatas. Azure.Core.Amqp: Сериализация не удалась из-за неподдерживаемого типа System.Byte[]. Кто-нибудь может помочь, пожалуйста? Я застрял в этом уже неделю. Спасибо
Я пытался привязать его к string[], и все работало нормально, но при использовании EventData[] не получилось.
У меня такая же проблема, я использую последнюю версию библиотек. Когда я использую string[], он работает, но как только я меняю его на EventData[], он терпит неудачу.
Файл проекта:
net7.0 v4 Exe последняя Program.cs:
с использованием Microsoft.Azure.Functions.Worker; использование Microsoft.Extensions.Hosting; вар хост = новый HostBuilder() .ConfigureFunctionsWorkerDefaults((IFunctionsWorkerApplicationBuilder _) => { }) .Строить(); хост.Выполнить(); Код функции:
с использованием Azure.Messaging.EventHubs; использование Microsoft.Azure.Functions.Worker; использование Microsoft.Extensions.Logging; пространство имен MyFunctionApp { открытый класс EventHubFunction { частный ILogger только для чтения _logger; public EventHubFunction (регистратор ILogger) { _logger = регистратор; } [Функция(имя(EventHubFunction)] public void Run([EventHubTrigger(Constants.EventHub, Connection = Constants.Connection, ConsumerGroup = Constants.ConsumerGroup, IsBatched = true)] EventData[] eventDatas) { foreach (var eventData в eventDatas) { //обработка сообщения } } } } Он никогда не попадает внутрь метода, и я получил следующую ошибку:
System.Private.CoreLib: исключение при выполнении функции: EventHubFunction. Microsoft.Azure.WebJobs.Host: параметр привязки исключения eventDatas. Azure.Core.Amqp: Сериализация не удалась из-за неподдерживаемого типа System.Byte[]. Кто-нибудь может помочь, пожалуйста? Я застрял в этом уже неделю. Спасибо
Я пытался привязать его к string[], и все работало нормально, но при использовании EventData[] не получилось.
Мобильная версия