0

我正在将现有的 c# .net 应用程序作为触发(按需,而不是使用队列/触发器/函数连续)网络作业运行。有时运行时间很长,比如 30 多分钟。效果很好。

[已编辑] 如果我尝试停止 webjob,通过在我的应用程序服务的应用程序设置中将 WEBJOBS_STOPPED 设置为 1,那么如果 Azure/Kudu 没有正常检测到关闭并及时终止,则 webjob 将被 Azure/Kudu 中止(5秒?30 秒?)

我已经尝试使用 WebJobsShutdownWatcher() 作为几个示例说明,并且正如 Joey 指出的那样,但它仍然没有检测到关闭,并且 Azure/Kudu 无论如何都会中止它。我什至手动编写了检查关闭文件是否存在的代码(请参阅 GitHub 中的 WebJobsShutdownWatcher() 代码),但该文件似乎没有为我的触发/按需网络作业创建,因此我的代码什么也没检测到。

我最初的问题是:WebJobsShutdownWatcher() 是否适用于 Triggered(OnDemand) 网络作业?还是仅适用于连续网络作业?我怀疑 WebJobsShutdownWatcher 只适用于 Continuous webjobs,所以在我花更多时间尝试调试它之前,我想在这里问一下。

我认为乔伊的回答有效,但我自欺欺人,因为控制台应用程序似乎因关闭而终止,但我现在认为它终止是因为我没有正确编码。无论如何,即使使用 .Register() 或检查 .Token.IsCancellationRequested,我的控制台应用程序似乎也没有收到通知,因此一旦我将 WEBJOBS_STOPPED 设置为 1,Azure/Kudu 就会中止它。

所以我开始想,也许还有其他 Azure 代码我必须添加到我的简单控制台应用程序中,我不知道,比如 JobHost 初始化和 host.RunAndBlock() 或类似的东西,让 Azure 做这件事并触发我使用 .Register 注册的匿名函数,或设置 .Token.IsCancellationRequested 标志。

我已经包含了我的整个简单测试程序,欢迎所有建议,尽管我会说我希望对我的 vanilla .NET 控制台应用程序进行最小的更改,我真的不想创建比我必须做的更多的东西,比如 JobHost (),或者触发了我必须在 Azure 中配置才能触发的功能。只是一个简单的控制台应用程序,带有一个带有 cron 计划的 settings.job,它运行和停止、运行和停止,如果它检测到 webjob 关闭,则提前终止以避免 Azure/Kudu 中止。

class Program
{
    static Boolean runFlag1 = true;
    static Boolean runFlag2 = true;
    static void Main(string[] args)
    {
        var watcher = new WebJobsShutdownWatcher();
        var cancellationToken = watcher.Token;
        cancellationToken.Register(() =>
        {
            Console.WriteLine("Webjob Shutdown signaled.");
            runFlag1 = false;
        });

        var t = Task.Run(() =>
        {
            Console.WriteLine("Beginning webjob loop...");
            while (runFlag1 && runFlag2)
            {
                Thread.Sleep(1000);
                Thread.Yield();

                if (watcher.Token.IsCancellationRequested)
                {
                    Console.WriteLine("");
                    Console.WriteLine("Webjob IsCancellationRequested=true");
                    runFlag2 = false;
                }
            }
            Console.WriteLine("");
            Console.WriteLine("Ending webjob loop, runFlag1={0} runFlag2={1}", runFlag1, runFlag2);
        });
        t.Wait();

        Console.WriteLine("Exited Task. runFlag1={0} runFlag2={1}", runFlag1, runFlag2);
    }
}

谢谢,博

4

1 回答 1

0

是的,您可以使用WebJobsShutdownWatcher该类,因为它具有Register在取消标记被取消时调用的函数,换句话说,当 web 作业停止时。

var cancellationToken = new WebJobsShutdownWatcher().Token;
cancellationToken.Register(() =>
{
    Console.Out.WriteLine("Do whatever you want before the webjob is stopped...");
});

如果您使用触发函数,则可以将CancellationToken参数添加到函数签名中。当主机自动关闭时,运行时将取消该令牌,从而允许您的函数接收通知。这是您可以参考的线程。

public static void QueueFunction(
        [QueueTrigger("QueueName")] string message,
        CancellationToken cancellationToken)
{
    if(cancellationToken.IsCancellationRequested) return;
    ...
}
于 2019-07-15T08:01:53.560 回答