Azure Durable Orchestration超时场景下WaitForExternalEvent输入丢失求助

方案1：超时后主动查询未处理的外部事件 #

Durable Functions中未被WaitForExternalEvent捕获的外部事件会被持久化存储在编排的状态中，你可以在超时分支里主动检查是否有遗漏的AlarmCommand事件：

TimeSpan timeout = TimeSpan.FromSeconds(30);
DateTime deadline = context.CurrentUtcDateTime.Add(timeout);

using var cts = new CancellationTokenSource();
var alarmTask = context.WaitForExternalEvent<AlarmMessage>("AlarmCommand");
var timeoutTask = context.CreateTimer(deadline, cts.Token);
_logger?.LogWarning($"Deadline: {deadline}");

var winner = await Task.WhenAny(alarmTask, timeoutTask);

if (winner == alarmTask)
{
    cts.Cancel();
    _logger?.LogWarning($"Input detected");
    // 处理收到的事件
    var alarmMessage = await alarmTask;
    // 成功逻辑
}
else
{
    _logger?.LogWarning($"Timeout reached");
    // 立即查询是否有未处理的AlarmCommand事件（0秒超时）
    var missedAlarm = await context.WaitForExternalEvent<AlarmMessage>("AlarmCommand", TimeSpan.FromSeconds(0));
    if (missedAlarm != null)
    {
        _logger?.LogWarning($"Caught missed alarm input");
        // 处理延迟到达的事件
        // 遗漏事件处理逻辑
    }
    else
    {
        // 真正的超时逻辑
    }
    cts.Cancel();
}

这里将WaitForExternalEvent的超时参数设为0秒，会立即返回是否存在已存储的未处理事件，不会等待新事件。

方案2：用持久化队列中转外部事件 #

把AlarmCommand输入先发送到Azure存储队列（或Service Bus队列），让编排在超时后主动从队列拉取消息，彻底避免事件丢失：

1. 发送外部事件时同步写入队列：

// 发送AlarmCommand到编排的同时，写入队列
var queueClient = new QueueClient(storageConnString, "alarm-backup-queue");
await queueClient.SendMessageAsync(JsonSerializer.Serialize(new { OrchestrationId = orchestrationId, Data = alarmMessage }));
await durableClient.RaiseEventAsync(orchestrationId, "AlarmCommand", alarmMessage);

2. 编排超时后从队列拉取对应消息：

// 超时分支逻辑
else
{
    _logger?.LogWarning($"Timeout reached");
    var queueClient = new QueueClient(storageConnString, "alarm-backup-queue");
    var messages = await queueClient.ReceiveMessagesAsync(maxMessages: 10, visibilityTimeout: TimeSpan.FromMinutes(5));
    
    foreach (var msg in messages.Value)
    {
        var backupMsg = JsonSerializer.Deserialize<dynamic>(msg.Body.ToString());
        // 验证消息是否属于当前编排实例
        if (backupMsg.OrchestrationId == context.InstanceId)
        {
            _logger?.LogWarning($"Found missed alarm in queue");
            // 处理消息
            // 队列消息处理逻辑
            await queueClient.DeleteMessageAsync(msg.MessageId, msg.PopReceipt);
            break;
        }
    }
    cts.Cancel();
}

方案3：缩短编排轮询间隔（仅限消费计划） #

如果使用消费计划，可以通过修改host.json中的配置缩短轮询间隔，减少超时触发的延迟：

{
  "extensions": {
    "durableTask": {
      "pollingInterval": "00:00:05", // 将轮询间隔缩短至5秒
      "controlQueueVisibilityTimeout": "00:00:30",
      "workItemQueueVisibilityTimeout": "00:00:30"
    }
  }
}

注意：缩短轮询间隔会增加存储账户的请求量，可能带来额外成本，需要根据业务场景权衡。

内容的提问来源于stack exchange，提问作者Kars