如何取消指定客户对应的单个Azure WebJob执行实例

取消队列方案可行性 #

你提出的专属取消队列方案是完全可行的，也是生产环境处理队列驱动类任务主动取消的主流实现思路，不需要依赖Azure平台额外的管控接口，完全可以通过业务逻辑层实现。

具体实现流程 #

• 首先为每一个进入处理队列的任务生成全局唯一的任务ID，将任务ID、客户标识、运行状态（运行中/待取消/已完成）存入Redis、Azure Table Storage等所有WebJob实例都可以访问的共享存储中，任务ID会随队列消息一起传递。
• 官网的「取消执行」按钮被点击后，后台做两个操作：第一在共享存储中将对应任务的状态更新为待取消，第二往专属取消队列写入携带目标任务ID的消息（可选，用于触发实时通知，降低轮询成本）。
• 原有WebJob的处理逻辑中增加取消状态检查逻辑，每完成一个最小粒度的业务处理单元就查询一次当前任务的状态，如果已经被标记为待取消，就主动释放占用的资源、记录取消日志后终止流程，同时标记队列消息处理完成，避免被放回队列重复执行。

CancellationToken的使用说明 #

必须配合CancellationToken一起使用，Azure WebJobs SDK原生支持给队列触发函数注入取消令牌，该令牌会在WebJob实例被平台回收（比如App Service缩放、站点重启、部署更新）时收到终止信号，和你自定义的业务取消标记配合可以覆盖所有终止场景。
修改后的参考代码如下：

public static void EngineForProcessQueue(
    [QueueTrigger(WebJobHelper.JOB_FOR_PROCESS_QUEUE)] string message, 
    TextWriter log,
    CancellationToken cancellationToken)
{
    // 解析消息中的任务ID
    var taskId = ParseTaskIdFromMessage(message);
    while(/* 处理流程未完成 */)
    {
        // 同时检查平台取消信号和业务侧取消标记
        if (cancellationToken.IsCancellationRequested || CheckTaskCancelStatus(taskId))
        {
            log.WriteLine($"任务{taskId}已取消，终止执行");
            // 这里补充资源释放逻辑
            return;
        }
        // 执行单步处理逻辑
        ProcessSingleStep();
    }
    ProcessQueueMessage(message, log);
}

注意事项 #

• 不要直接通过进程Kill的方式终止WebJob实例，否则未标记处理完成的队列消息会被Azure自动放回队列，导致任务重复执行。
• 长时间运行的处理流程必须拆分为多个小粒度的执行单元，避免长时间无法触发取消检查，导致取消延迟过高。

内容的提问来源于stack exchange，提问作者Arthur Paiva Camilo