如何将 EventData 传递给持久函数？

Question

我想从 EventHubTrigger azure 函数运行持久函数。

        public async Task<bool> Activities(
            [EventHubTrigger(EventHubName, Connection = EventHubConnStrName)] EventData[] events,
            [DurableClient] IDurableOrchestrationClient durableClient,
            ILogger logger)
        {
                // chaining pattern durable function
                 await durableClient.StartNewAsync<string>(
                       FunctionNames.BatchEvents,
                       JsonConvertUtil.SerializeObject(events));
           
        } 

        [FunctionName(FunctionNames.BatchEvents)]
        public static async Task<bool> Run(
           [OrchestrationTrigger] IDurableOrchestrationContext context,
            ILogger logger)
        {
            try
            {
                var events = 
                    JsonConvertUtil.DeserializeObject<EventData[]>(context.GetInput<string>()));

                ....
            }
            catch (Exception ex)
            {
                logger.LogError(ex.Message);
                throw;
            }
        }

让我知道如何将事件传递给持久函数或者我可以更好地设计它？

Answer 1

我相信在阅读此内容后，您编写在 Azure Durable Functions 中传递事件数据的工作流程的方式是有意义的 基于事件的带有持久功能的工作流程。

 var events = 
             JsonConvertUtil.DeserializeObject<EventData[]>(context.GetInput<string>()));

在您的代码中，您使用了 context.GetInput 方法来解压您传递的事件数据，并反序列化为 JSON。

在上面的文章中，有一些有关在 Azure Durable Functions 中使用基于事件的触发数据的工作流程的信息，可能会对您有所帮助。