是否可以创建一个可以从 EventHub 的多个事件触发的编排持久函数？

Question

我想这是一个与类似的问题，但我本身并没有尝试多个触发器。

我的用例是我有一个触发持久函数的 EventHub。我想监听第 N 个事件，其中包含特定 ID 的有效负载中的特定模式（也在有效负载中）

当收到第n个事件时，我可以轻松地启动另一个activity，但我能解决的是如何在开始时进行状态位？

如果持久函数无法支持此功能，Azure 中还有哪些其他选项可以做类似的事情？

event       id      event name
1           1       login
2           1       navigate
3           2       login
4           2       do something
5           1       do something of interest
6           1       do something of interest (again, this is what I was to trigger the activity on)

此信息当前来自事件中心并触发我的功能。

Answer 1

这可能是 Durable Entities（Durable Functions 的新功能）的一个很好的用例。您的实体的 ID 可以从您的事件负载中的 ID 派生。从您的 EventHub 触发器功能，您可以在每次看到您正在寻找的模式时向特定实体发送信号。持久实体将在第一个事件到达时自动创建，并且可以在采取某些操作之前简单地计算事件的数量。

例如，这里是事件中心触发器函数：

[FunctionName("ProcessEvents")]
public static async Task ProcessEvents(
    [EventHubTrigger("event-source")] EventData input,
    [DurableClient] IDurableClient client)
{
    if (IsOfInterest(input))
    {
        var id = new EntityId("MyDetector", (string)input.Properties["ID"]);
        await client.SignalEntityAsync(id, nameof(MyDetector.Process), input);
    }

    // ...
}

...这是实体函数（作为 .NET class 实现）：

[JsonObject(MemberSerialization.OptIn)]
public class MyDetector
{
    [JsonProperty]
    public int CurrentEventCount { get; set; }

    public void Process(EventData input) 
    {
        // Take some action if this event happens N or more times
        if (++this.CurrentEventCount >= 10)
        {
            TakeSomeAction(input);

            // reset the counter
            this.CurrentEventCount = 0;
        }
    }

    [FunctionName(nameof(MyDetector))]
    public static Task Run([EntityTrigger] IDurableEntityContext ctx)
        => ctx.DispatchAsync<MyDetector>();
}

是否可以创建一个可以从 EventHub 的多个事件触发的编排持久函数？

Is it possible to create an orchestration durable function that can be triggered from multiple events from an EventHub?

c#

azure

azure-functions

azure-durable-functions