В настоящее время я работаю над некоторыми функциями Azure, которые запускаются сообщениями EventHub, отформатированными в JSON.EventHub имеет два раздела и имеет одну группу потребителей.Большинство вызовов функций работают правильно, но случайно возникают ошибочные вызовы, которые в основном представляют собой два или более сообщений, упакованных вместе.
Мой триггер выглядит следующим образом:
public static void Run(
[EventHubTrigger("eh-in", Connection = "eh-in-connection")] EventData dmyEventHubMessage,
[EventHub("eh-out", Connection = "eh-out-connection")] out string outEventHubMessage,
TraceWriter log)
Я также пыталсяпривязать к самому сообщению через
public static void Run(
[EventHubTrigger("eh-in", Connection = "eh-in-connection")] string myEventHubMessage,
[EventHub("eh-out", Connection = "eh-out-connection")] out string outEventHubMessage,
TraceWriter log)
, но с теми же ошибками.Сообщение выглядит так: {myfirstmessage}{mysecondmessage}
.
У вас есть идеи, почему это может произойти и как этого избежать?