Блог

У нас есть много файлов, которые создаются в хранилище больших двоичных объектов, и, следовательно, мы передаем эти файлы функциям Azure. Однако с помощью функции Azure и триггера сетки событий время ожидания истекло после определенного нет. количество файлов было обработано. Поэтому сейчас я пытаюсь использовать долговременные функции.

Ниже приведен код, который я пробовал.

Запускается ProcessJob_EventGrid. Однако ProcessJob_Orchestrator никогда не запускается. Есть ли что-то, чего мне не хватает.

Я совершенно новичок в концепции долговременных функций.

 [FunctionName("ProcessJob_Orchestrator")]
        public async Task RunOrchestrator(
            [OrchestrationTrigger] IDurableOrchestrationContext context, ILogger log)
        {
            log.LogInformation($"************** RunOrchestrator method executing ********************");
            var data = context.GetInput<string>();
            log.LogInformation($"File Name is  {data}.");
            //// Replace "hello" with the name of your Durable Activity Function.
            //outputs.Add(await context.CallActivityAsync<string>("MCNDataTransformation_Hello", "Tokyo"));
            //outputs.Add(await context.CallActivityAsync<string>("MCNDataTransformation_Hello", "Seattle"));
            //outputs.Add(await context.CallActivityAsync<string>("MCNDataTransformation_Hello", "London"));

            //// returns ["Hello Tokyo!", "Hello Seattle!", "Hello London!"]
            //return outputs;
        }

        [FunctionName("MCNDataTransformation_Hello")]
        public string SayHello([ActivityTrigger] string name, ILogger log)
        {
            log.LogInformation($"Saying hello to {name}.");
            return $"Hello {name}!";
        }

        [FunctionName("ProcessJob_EventGrid")]
        public static async void EventGridTest([EventGridTrigger] EventGridEvent eventGridEvent, [DurableClient] IDurableOrchestrationClient starter, ILogger log)
        {
            JObject objData = JObject.Parse(eventGridEvent.Data.ToString());

            // Function input comes from the request content.
            string instanceId = await starter.StartNewAsync("ProcessJob_Orchestrator", null, JsonConvert.SerializeObject(objData));

            log.LogInformation(eventGridEvent.Data.ToString());
        }
 

Я являюсь членом команды разработчиков Durable Functions 🙂 Ничто сразу не выделяется как неправильное. Однако передача null в качестве 2-го параметра StartNewAsync немного подозрительна: если вы не пытаетесь вызвать определенный InstanceID , у вас не должно быть причин указывать это значение.

Как насчет того, чтобы попробовать переписать эту строку, чтобы быть:

 // Do not specify instanceId argument if not needed.
string instanceId = await starter.StartNewAsync("ProcessJob_Orchestrator", JsonConvert.SerializeObject(objData));
 

Возможно, этого должно хватить. Пожалуйста, дайте мне знать, если это произойдет!

Если это не решит вашу проблему, есть несколько последующих шагов, которые вы можете предпринять.

1. Локально проверьте предварительно скомпилированные образцы здесь: https://github.com/Azure/azure-functions-durable-extension/tree/dev/samples/precompiled Там попробуйте запустить простую оркестровку, например HelloSequence . Если вам удастся запустить его, попробуйте изменить его в соответствии с вашим вариантом использования.
2. Если ни один из вышеперечисленных советов не сработает, откройте тикет в https://github.com/Azure/azure-functions-durable-extension/issues и мы немедленно взглянем на это!