У меня есть функция Azure, которая использует триггер ServiceBus с темами. Недавно я добавил correlationId в список привязываемых входных данных, однако correlationId не является обязательным. Я подтвердил, что идентификатор корреляции установлен во входящем сообщении. Все инструменты / NuGets находятся на последних битах (на сегодняшний день).
Функция также является долговременной, что очевидно из следующего фрагмента кода
[FunctionName("TopicHandler")]
public static void Run([ServiceBusTrigger("%TopicName%", "SubscriptionName", Connection = "ServiceBusConnection")]string messageBody,
string label,
string messageId,
string correlationId,
IDictionary<string, object> userProperties,
[OrchestrationClient] DurableOrchestrationClient starter,
ExecutionContext executionContext,
ILogger logger)
{
....
Документация предполагает, что это должно работать:
https://docs.microsoft.com/en-us/azure/azure-functions/functions-bindings-service-bus#trigger---message-metadata
Однако это не полностью объясняет, работает ли он только с очередями или нет.
https://docs.microsoft.com/en-us/azure/service-bus-messaging/service-bus-messages-payloads#message-routing-and-correlation
Любые рекомендации приветствуются, прежде чем я создаю пользовательское свойство.