是否有一种模式或简便的方法来取消Azure WebJob函数中的特定运行

问题描述

在我的多租户应用程序中，我有一个在Webjob中运行的后台进程，可能需要几分钟。时间因每个客户的数据而异。

但是有时候，当我测试某些东西时，我开始了该过程，并（查看日志）很快就发现出了点问题，我想取消该特定运行。

我不能仅仅杀死队列中的所有消息或停止WebJob，因为我要杀死正在为其他客户运行的进程。

我想以编程方式进行操作，因此可以在Web应用程序中放置一个“取消”按钮。

我找不到最佳的架构方法（或模式）来解决这种执行取消问题。 我读过有关传递CancellationTokenSource的信息，但是我想不起来如何在要取消的特定运行中调用Cancel()方法。是否应该将所有当前正在运行的令牌存储在静态类中？然后向网络作业发送另一条消息，告诉我我要取消它？

（我想这可能是答案，但是我怕我想得太过分了。这就是为什么我在这里问这个问题。）

我的功能很简单：

 public static void EngineProcessQueue([QueueTrigger("job-for-process")] string message,TextWriter log)
 {
     // Inside this method there is a huge codebase
     // and I'm afraid that I'll have to put the "if (token.IsCancelled)" in lots of places...
     // (but that's another question)
     ProcessQueueMessage(message,log); 
 }

解决方法

class Pie constructor( val fillingA: String,val fillingB: String? = null,val fillingC: String? = null,val topping: String? = null ){...} 本质上是一个函数触发器。您需要的QueueTrigger不受支持。

由于一旦输入了函数执行方法，则特定的业务逻辑代码可能具有异步操作。假设即使我们此时删除或停止Cancel，业务数据也会受到影响，并且无法实现回滚。

以下是我的个人建议，

因为我认为可以通过业务逻辑来改进取消操作：

1. 使用redis缓存，并创建对象名称QueueTrigger，以存储您的业务命令。

2. 运行webjob时，我们可以获取所有mypools，也可以在Queue中找到。然后我们可以使用特定命令将其保存在Azure Storage Explore中。

3. 命令的格式应为mypools。例如ClientName-TriggerName-Status-Extend，当此命令尚未执行时，我们可以使用Acompany-jobforprocess-run-null对其进行修改。

4. 我们可以 set Azure WebJob queue name at runtime。。然后在程序中动态处理业务。对于已执行的业务，将执行数据回滚。