如何使用 Azure WebJobs SDK 進行事件驅動幕後處理

發行項
06/01/2023

本文提供有關如何使用 Azure WebJobs SDK 的指引。若要立即開始使用 WebJobs，請參閱開始使用 Azure WebJobs SDK。

WebJobs SDK 版本

3.x 版與 2.x 版的 WebJobs SDK 之間有主要的差異：

3.x 版新增對於 .NET Core 的支援。
在 3.x 版中，您將安裝 WebJobs SDK 所需的儲存體繫結延伸模組。在 2.x 版中，儲存體繫結包含於 SDK 中。
適用於 .NET Core 的 2019 年 Visual Studio 工具 (3.x) 專案與適用於 .NET Framework 的工具 (2.x) 專案不同。若要深入了解，請參閱使用 Visual Studio 開發和部署 WebJob - Azure App Service。

本文中的數個描述為 WebJobs 3. x 版 WebJobs 2. x 版提供範例。

Azure Functions 就是以 WebJobs SDK 為基礎建置的。

Azure Functions 第 2.x 版是以 WebJobs SDK 3.x 版為基礎所建置。
Azure Functions 第 1.x 版是以 WebJobs SDK 2.x 版為基礎所建置。

Azure Functions 和 WebJobs SDK 的原始程式碼儲存機制都使用 WebJobs SDK 編號。本操作說明文中數個章節都連結至 Azure Functions 文件。

如需詳細資訊，請參閱比較 WebJobs SDK 和 Azure Functions

WebJobs 主機

此主機是函式的執行階段容器。主機會接聽觸發程序並呼叫函式。在 3.x 版中，主機是 IHost 的實作。在 2.x 版中，您是使用 JobHost 物件。您可以在程式碼中建立主機執行個體，並撰寫程式碼以自訂其行為。

這是 WebJobs SDK 直接使用與透過 Azure Functions 間接使用之間的主要差異。在 Azure Functions 中，服務會控制主機，且您無法藉由撰寫程式碼來自訂主機。 Azure Functions 可讓您透過設定 host.json 檔案自訂主機行為。這些設定是字串，不是程式碼，使用這些字串會限制您可以進行自訂的種類。

主機連接字串

當您在本機或 Azure 中執行時位於 WebJob 的環境中，WebJobs SDK 會在 local.settings.json 檔案中尋找 Azure 儲存體與 Azure 服務匯流排連接字串。根據預設，WebJobs SDK 需要具有名稱 AzureWebJobsStorage 的儲存體連接字串設定。

2.x 版的 SDK 不需要特定名稱。 2.x 版可讓您自行為這些連接字串命名，並允許您儲存於他處。您可以使用 JobHostConfiguration 在程式碼中設定名稱，例如：

static void Main(string[] args)
{
    var _storageConn = ConfigurationManager
        .ConnectionStrings["MyStorageConnection"].ConnectionString;

    //// Dashboard logging is deprecated; use Application Insights.
    //var _dashboardConn = ConfigurationManager
    //    .ConnectionStrings["MyDashboardConnection"].ConnectionString;

    JobHostConfiguration config = new JobHostConfiguration();
    config.StorageConnectionString = _storageConn;
    //config.DashboardConnectionString = _dashboardConn;
    JobHost host = new JobHost(config);
    host.RunAndBlock();
}

注意

由於 3.x 版使用預設的 .NET Core 設定 API，因此沒有 API 可用來變更連接字串名稱。請參閱使用 Visual Studio 開發和部署 WebJob

主機開發設定

您可以在開發模式中執行主機，讓本機開發更有效率。以下是在開發模式中執行時自動變更的一些設定：

屬性	開發設定
`Tracing.ConsoleLevel`	`TraceLevel.Verbose` 將記錄輸出最大化。
`Queues.MaxPollingInterval`	最低值可確保立即觸發佇列方法。
`Singleton.ListenerLockPeriod`	15 秒在快速反覆式開發法中有幫助。

啟用開發模式的程序，取決於 SDK 版本。

3.x 版

3.x 版使用標準 ASP.NET Core API。在 HostBuilder 執行個體上呼叫 UseEnvironment 方法。傳入名為 development 的字串，如下列範例所示：

static async Task Main()
{
    var builder = new HostBuilder();
    builder.UseEnvironment("development");
    builder.ConfigureWebJobs(b =>
            {
                b.AddAzureStorageCoreServices();
            });
    var host = builder.Build();
    using (host)
    {
        await host.RunAsync();
    }
}

2.x 版

JobHostConfiguration 類別具有可啟用開發模式的 UseDevelopmentSettings 方法。下列範例示範如何使用開發設定。在本機執行時，若要讓 config.IsDevelopment 傳回 true，請將本機環境變數設定為名為 AzureWebJobsEnv 且值為 Development。

static void Main()
{
    config = new JobHostConfiguration();

    if (config.IsDevelopment)
    {
        config.UseDevelopmentSettings();
    }

    var host = new JobHost(config);
    host.RunAndBlock();
}

管理並行連線 (2.x 版)

在 3.x 版中，連線限制預設為無限連線。如果您因故需要變更此限制，可以使用 WinHttpHandler 類別的 MaxConnectionsPerServer 屬性。

在 2.x 版中，您可以使用 ServicePointManager.DefaultConnectionLimit API 來控制主機的並行連線數目。在 2.x 版中，您應在啟動 WebJobs 主機之前從預設值 2 增加此值。

所有您使用 HttpClient 從某個函式產生的外寄 HTTP 要求都會流經 ServicePointManager。當您達到 DefaultConnectionLimit 中設定的值之後，ServicePointManager 會在傳送要求之前先將其排入佇列。假設您的 DefaultConnectionLimit 設為 2，且您的程式碼會發出 1,000 個 HTTP 要求。一開始，只允許兩個要求傳至作業系統。其他的 998 個要求會排入佇列，直到有足夠的空間給這些要求。這表示您的 HttpClient 可能會逾時，因為其似乎已發出要求，但作業系統一直未將該要求傳送到目的地伺服器。因此，您可能會看到一個似乎不合理的行為：您的本機 HttpClient 花費 10 秒完成要求，但您的服務正以 200 毫秒的時間傳回每個要求。

ASP.NET 應用程式的預設值是 Int32.MaxValue，而且可能適用於在基本或更高等級 App Service 方案中執行的 WebJobs。 WebJobs 通常需要 [一律開啟] 設定，且只有基本與更高等級的 App Service 方案才支援。

如果 WebJob 正在免費或共用的 App Service 方案中執行，則您的應用程式會受到 App Service 沙箱的限制，沙箱目前的連線限制為 300。在 ServicePointManager 的未繫結連線限制下，更有可能到達沙箱連線閾值，且網站會關閉。在此狀況下，將 DefaultConnectionLimit 設為更低的值，如 50 或 100，可防止這種狀況發生，同時仍允許有足夠的輸送量。

此設定必須先設定，才能發出任何 HTTP 要求。基於這個理由，WebJobs 主機不應自動調整設定。可能會有在主機啟動之前發生的 HTTP 要求，這可能會導致非預期的行為。最佳方法就是先在 Main 方法中立即設定值，然後初始化 JobHost，如下所示：

static void Main(string[] args)
{
    // Set this immediately so that it's used by all requests.
    ServicePointManager.DefaultConnectionLimit = Int32.MaxValue;

    var host = new JobHost();
    host.RunAndBlock();
}

觸發程序

WebJobs SDK 支援與 Azure Functions 所使用相同的觸發程序和繫結集合。請注意，WebJobs SDK 中，觸發程序是函式特定的，與 WebJob 部署類型無關。使用 SDK 建立配合事件觸發函式的 WebJobs 應該一律發佈為連續 WebJob，並啟用 [一律開啟]。

Functions 必須是公用方法，且必須有一個觸發屬性與 NoAutomaticTrigger 屬性。

自動觸發程序

自動觸發程序會呼叫函式以回應事件。請考量此函式範例，此函式是由新增至 Azure 佇列儲存體的訊息所觸發。該功能會藉由從 Azure Blob 儲存體讀取 Blob 來回應：

public static void Run(
    [QueueTrigger("myqueue-items")] string myQueueItem,
    [Blob("samples-workitems/{queueTrigger}", FileAccess.Read)] Stream myBlob,
    ILogger log)
{
    log.LogInformation($"BlobInput processed blob\n Name:{myQueueItem} \n Size: {myBlob.Length} bytes");
}

QueueTrigger 屬性會告知執行階段，每當 myqueue-items 中出現佇列訊息時，就呼叫該函式。 Blob 屬性會告知執行階段使用佇列訊息來讀取 sample-workitems 容器中的 Blob。 samples-workitems 容器中的 Blob 項目名稱是直接從佇列觸發程序取得，作為繫結運算式 ({queueTrigger})。

注意

Web 應用程式會在閒置超過 20 分鐘後逾時，而且只有針對實際 Web 應用程式的要求，才可重設計時器。在 Azure 入口網站中檢視應用程式的組態，或者對進階工具網站 (https://<app_name>.scm.azurewebsites.net) 提出要求，並不會重設計時器。如果您設定裝載工作的 Web 應用程式為持續執行、依排程執行或使用事件驅動觸發程序，請在 Web 應用程式的 Azure [設定] 頁面上啟用 [一律開啟] 設定。 [一律開啟] 設定有助於確保這些類型的 WebJobs 得以可靠地執行。這項功能僅適用於基本、標準和進階定價層。

手動觸發程序

若要手動觸發函式，請使用 NoAutomaticTrigger 屬性，如下所示：

[NoAutomaticTrigger]
public static void CreateQueueMessage(
ILogger logger,
string value,
[Queue("outputqueue")] out string message)
{
    message = value;
    logger.LogInformation("Creating queue message: ", message);
}

手動觸發函式的程序取決於 SDK 版本。

3.x 版

static async Task Main(string[] args)
{
    var builder = new HostBuilder();
    builder.ConfigureWebJobs(b =>
    {
        b.AddAzureStorageCoreServices();
        b.AddAzureStorage();
    });
    var host = builder.Build();
    using (host)
    {
        var jobHost = host.Services.GetService(typeof(IJobHost)) as JobHost;
        var inputs = new Dictionary<string, object>
        {
            { "value", "Hello world!" }
        };

        await host.StartAsync();
        await jobHost.CallAsync("CreateQueueMessage", inputs);
        await host.StopAsync();
    }
}

2.x 版

static void Main(string[] args)
{
    JobHost host = new JobHost();
    host.Call(typeof(Program).GetMethod("CreateQueueMessage"), new { value = "Hello world!" });
}

輸入與輸出繫結

輸入繫結會提供宣告式方法，讓 Azure 或協力廠商服務中的資料可供您的程式碼使用。輸出繫結會提供更新資料的方法。開始使用一文提供每個繫結的範例。

您可以藉由將屬性套用至方法傳回值，將方法傳回值用於輸出繫結。請參閱使用 Azure Function 傳回值中的範例。

繫結型別

安裝和管理繫結類型的程序，取決於您使用的是 3.x 版或 2.x 的 SDK。您可以在該繫結類型 Azure Functions 參考文章的「套件」一節中，找到可為特定繫結類型安裝的套件。有一個例外狀況，就是檔案觸發程序與繫結 (針對本機檔案系統)，其不受 Azure Functions 支援。

3.x 版

在 3.x 版中，儲存體繫結包含於 Microsoft.Azure.WebJobs.Extensions.Storage 套件中。在 ConfigureWebJobs 方法中呼叫 AddAzureStorage 擴充方法，如下所示：

static async Task Main()
{
    var builder = new HostBuilder();
    builder.ConfigureWebJobs(b =>
            {
                b.AddAzureStorageCoreServices();
                b.AddAzureStorage();
            });
    var host = builder.Build();
    using (host)
    {
        await host.RunAsync();
    }
}

若要使用其他觸發程序與繫結類型，請安裝包含這些項目的 NuGet 套件，並呼叫在擴充功能中實作的 Add<binding> 擴充方法。例如，如果您要使用 Azure Cosmos DB 繫結，請安裝 Microsoft.Azure.WebJobs.Extensions.CosmosDB 並呼叫 AddCosmosDB，如下所示：

static async Task Main()
{
    var builder = new HostBuilder();
    builder.ConfigureWebJobs(b =>
            {
                b.AddAzureStorageCoreServices();
                b.AddCosmosDB();
            });
    var host = builder.Build();
    using (host)
    {
        await host.RunAsync();
    }
}

若要使用核心服務中包含的計時器觸發程序或檔案繫結，請呼叫 AddTimers 或 AddFiles 擴充方法。

2.x 版

這些觸發程序與繫結類型包含於 2.x 版的 Microsoft.Azure.WebJobs 套件中：

Blob 儲存體
佇列儲存體
表格儲存體

若要使用其他觸發程序與繫結型別，請安裝包含它們的 NuGet 封裝，並在 JobHostConfiguration 物件上呼叫 Use<binding> 方法。例如，如果您想要使用計時器觸發程序，請安裝 Microsoft.Azure.WebJobs.Extensions 並呼叫 Main 方法的 UseTimers，如下所示：

static void Main()
{
    config = new JobHostConfiguration();
    config.UseTimers();
    var host = new JobHost(config);
    host.RunAndBlock();
}

若要使用檔案繫結，請安裝 Microsoft.Azure.WebJobs.Extensions 並呼叫 UseFiles。

ExecutionContext

WebJobs 可讓您繫結至 ExecutionContext。透過此繫結，您將可存取函式簽章中的參數 ExecutionContext。例如，下列程式碼會使用內容物件存取引動過程識別碼，而您可以使用此識別碼讓給定的函式引動過程所產生的所有記錄相互關聯。

public class Functions
{
    public static void ProcessQueueMessage([QueueTrigger("queue")] string message,
        ExecutionContext executionContext,
        ILogger logger)
    {
        logger.LogInformation($"{message}\n{executionContext.InvocationId}");
    }
}

繫結至 ExecutionContext 的程序取決於您的 SDK 版本。

3.x 版

在 ConfigureWebJobs 方法中呼叫 AddExecutionContextBinding 擴充方法，如下所示：

static async Task Main()
{
    var builder = new HostBuilder();
    builder.ConfigureWebJobs(b =>
            {
                b.AddAzureStorageCoreServices();
                b.AddExecutionContextBinding();
            });
    var host = builder.Build();
    using (host)
    {
        await host.RunAsync();
    }
}

2.x 版

先前所提到的 Microsoft.Azure.WebJobs.Extensions 封裝方法也提供特殊的繫結型別，您可以呼叫 UseCore 方法來註冊該繫結型別。此繫結可讓您定義函式簽章中的 ExecutionContext 參數，其啟用方式如下：

class Program
{
    static void Main()
    {
        config = new JobHostConfiguration();
        config.UseCore();
        var host = new JobHost(config);
        host.RunAndBlock();
    }
}

繫結設定

您可以設定某些觸發程序和繫結的行為。設定的程序取決於 SDK 版本。

版本 3.x：在 ConfigureWebJobs 中呼叫 Add<Binding> 方法時，就會進行設定。
版本 2.x：在您傳至 JobHost 的設定物件中設定屬性，就會進行設定。

這些繫結特定設定相當於 Azure Functions 中 host.json 專案檔中的設定。

您可以設定下列繫結：

Azure Cosmos DB 觸發程序
事件中樞觸發程序
佇列儲存體觸發程序
SendGrid 繫結
服務匯流排觸發程序

Azure Cosmos DB 觸發程序設定 (3.x 版)

這個範例顯示如何設定 Azure Cosmos DB 觸發程序：

static async Task Main()
{
    var builder = new HostBuilder();
    builder.ConfigureWebJobs(b =>
    {
        b.AddAzureStorageCoreServices();
        b.AddCosmosDB(a =>
        {
            a.ConnectionMode = ConnectionMode.Gateway;
            a.Protocol = Protocol.Https;
            a.LeaseOptions.LeasePrefix = "prefix1";

        });
    });
    var host = builder.Build();
    using (host)
    {
        await host.RunAsync();
    }
}

如需詳細資訊，請參閱 Azure Cosmos DB 繫結一文。

事件中樞觸發程序設定 (3.x 版)

這個範例顯示如何設定事件中樞觸發程序：

static async Task Main()
{
    var builder = new HostBuilder();
    builder.ConfigureWebJobs(b =>
    {
        b.AddAzureStorageCoreServices();
        b.AddEventHubs(a =>
        {
            a.BatchCheckpointFrequency = 5;
            a.EventProcessorOptions.MaxBatchSize = 256;
            a.EventProcessorOptions.PrefetchCount = 512;
        });
    });
    var host = builder.Build();
    using (host)
    {
        await host.RunAsync();
    }
}

如需詳細資訊，請參閱事件中樞繫結文章。

佇列儲存體觸發程序設定

下列範例示範如何設定佇列儲存體觸發程序。

3.x 版

static async Task Main()
{
    var builder = new HostBuilder();
    builder.ConfigureWebJobs(b =>
    {
        b.AddAzureStorageCoreServices();
        b.AddAzureStorage(a => {
            a.BatchSize = 8;
            a.NewBatchThreshold = 4;
            a.MaxDequeueCount = 4;
            a.MaxPollingInterval = TimeSpan.FromSeconds(15);
        });
    });
    var host = builder.Build();
    using (host)
    {
        await host.RunAsync();
    }
}

如需詳細資訊，請參閱佇列儲存體繫結一文。

2.x 版

static void Main(string[] args)
{
    JobHostConfiguration config = new JobHostConfiguration();
    config.Queues.BatchSize = 8;
    config.Queues.NewBatchThreshold = 4;
    config.Queues.MaxDequeueCount = 4;
    config.Queues.MaxPollingInterval = TimeSpan.FromSeconds(15);
    JobHost host = new JobHost(config);
    host.RunAndBlock();
}

如需詳細資訊，請參閱 host.json v1.x 參考。

SendGrid 繫結設定 (3.x 版)

這個範例顯示如何設定 SendGrid 輸出繫結：

static async Task Main()
{
    var builder = new HostBuilder();
    builder.ConfigureWebJobs(b =>
    {
        b.AddAzureStorageCoreServices();
        b.AddSendGrid(a =>
        {
            a.FromAddress.Email = "samples@functions.com";
            a.FromAddress.Name = "Azure Functions";
        });
    });
    var host = builder.Build();
    using (host)
    {
        await host.RunAsync();
    }
}

如需詳細資訊，請參閱 SendGrid 繫結文章。

服務匯流排觸發程序設定 (3.x 版)

這個範例顯示如何設定服務匯流排觸發程序：

static async Task Main()
{
    var builder = new HostBuilder();
    builder.ConfigureWebJobs(b =>
    {
        b.AddAzureStorageCoreServices();
        b.AddServiceBus(sbOptions =>
        {
            sbOptions.MessageHandlerOptions.AutoComplete = true;
            sbOptions.MessageHandlerOptions.MaxConcurrentCalls = 16;
        });
    });
    var host = builder.Build();
    using (host)
    {
        await host.RunAsync();
    }
}

如需詳細資訊，請參閱服務匯流排繫結一文。

其他繫結的設定

某些觸發程序與繫結類型會定義自己的自訂設定類型。例如，檔案觸發程序可讓您指定要監視的根路徑，如下列範例所示。

3.x 版

static async Task Main()
{
    var builder = new HostBuilder();
    builder.ConfigureWebJobs(b =>
    {
        b.AddAzureStorageCoreServices();
        b.AddFiles(a => a.RootPath = @"c:\data\import");
    });
    var host = builder.Build();
    using (host)
    {
        await host.RunAsync();
    }
}

2.x 版

static void Main()
{
    config = new JobHostConfiguration();
    var filesConfig = new FilesConfiguration
    {
        RootPath = @"c:\data\import"
    };
    config.UseFiles(filesConfig);
    var host = new JobHost(config);
    host.RunAndBlock();
}

繫結運算式

在屬性建構函式參數中，您可以使用運算式來解析各種來源的值。例如，在下列程式碼中，BlobTrigger 屬性的路徑會建立名為 filename。當用於輸出繫結時，filename 會解析觸發中二進位大型物件的名稱。

public static void CreateThumbnail(
    [BlobTrigger("sample-images/{filename}")] Stream image,
    [Blob("sample-images-sm/{filename}", FileAccess.Write)] Stream imageSmall,
    string filename,
    ILogger logger)
{
    logger.Info($"Blob trigger processing: {filename}");
    // ...
}

如需繫結運算式的詳細資訊，請參閱 Azure Functions 文件中的繫結運算式和模式 (英文)。

自訂繫結運算式

有時候您不想要採取硬式編碼的方式，而是在程式碼中指定佇列名稱、Blob 名稱或容器或資料表名稱。例如，您可能想要在設定檔或環境變數中指定 QueueTrigger 屬性的佇列名稱。

您可以在設定期間傳遞自訂名稱解析程式來執行此動作。在觸發程序或繫結屬性建構函式中包含預留位置，然後解析程式程式碼會提供實際要用以取代這些預留位置的值。您可以用百分比 (%) 符號括住預留位置來加以識別，如下所示：

public static void WriteLog([QueueTrigger("%logqueue%")] string logMessage)
{
    Console.WriteLine(logMessage);
}

此程式碼可讓您在測試環境中使用名為 logqueuetest 的佇列，以及在生產環境中使用名為 logqueueprod 的佇列。您不必使用硬式編碼的佇列名稱，而是在 appSettings 集合中指定項目的名稱。

如果您沒有提供自訂名稱，則預設的解析程式會生效。此預設值會從應用程式設定或環境變數取得值。

從 .NET Core 3.1 開始，您使用的 ConfigurationManager 需要 System.Configuration.ConfigurationManager NuGet 套件。此範例需要下列 using 陳述式：

using System.Configuration;

NameResolver 類別會從應用程式設定取得佇列名稱，如下所示：

public class CustomNameResolver : INameResolver
{
    public string Resolve(string name)
    {
        return ConfigurationManager.AppSettings[name].ToString();
    }
}

3.x 版

您可以使用相依性插入來設定解析程式。這些範例需要下列 using 陳述式：

using Microsoft.Extensions.DependencyInjection;

您可以藉由在 HostBuilder 上呼叫 ConfigureServices 擴充方法來新增解析程式，如下列範例所示：

static async Task Main(string[] args)
{
    var builder = new HostBuilder();
    var resolver = new CustomNameResolver();
    builder.ConfigureWebJobs(b =>
    {
        b.AddAzureStorageCoreServices();
    });
    builder.ConfigureServices(s => s.AddSingleton<INameResolver>(resolver));
    var host = builder.Build();
    using (host)
    {
        await host.RunAsync();
    }
}

2.x 版

將 NameResolver 類別傳入 JobHost 物件，如下所示：

 static void Main(string[] args)
{
    JobHostConfiguration config = new JobHostConfiguration();
    config.NameResolver = new CustomNameResolver();
    JobHost host = new JobHost(config);
    host.RunAndBlock();
}

Azure Functions 會實作 INameResolver，以從應用程式設定取得值，如下面範例所示。當您直接使用 WebJobs SDK 時，您可以撰寫自訂實作，以從任何您偏好的來源取得預留位置取代值。

執行階段的繫結

如果您需要先在函式中執行部分工作，然後再使用繫結屬性，例如 Queue、Blob 或 Table，您可以使用 IBinder 介面。

下列範例會使用輸入佇列訊息，並在輸出佇列中建立含有相同內容的新訊息。輸出佇列名稱會由函數主體中的程式碼設定。

public static void CreateQueueMessage(
    [QueueTrigger("inputqueue")] string queueMessage,
    IBinder binder)
{
    string outputQueueName = "outputqueue" + DateTime.Now.Month.ToString();
    QueueAttribute queueAttribute = new QueueAttribute(outputQueueName);
    CloudQueue outputQueue = binder.Bind<CloudQueue>(queueAttribute);
    outputQueue.AddMessageAsync(new CloudQueueMessage(queueMessage));
}

如需詳細資訊，請參閱 Azure Functions 文件中的執行階段的繫結 (英文)。

繫結參考資訊

Azure Functions 文件中會提供每個繫結類型的相關參考資訊。您將會在每個繫結參考文章中找到下列資訊。 (此範例是根據儲存體佇列。)

套件。您需要安裝的套件，以在 WebJobs SDK 專案中納入繫結的支援。
範例。程式碼範例。 C# 類別庫範例適用於 WebJobs SDK。只要省略 FunctionName 屬性。
屬性。用於繫結類型的屬性。
設定。屬性 (attribute) 屬性 (property) 與建構函式參數的說明。
使用情況。您可以繫結至哪些類型，以及繫結運作方式的相關資訊。例如：輪詢演算法、有害佇列處理。

注意

HTTP、Webhook 和事件方格繫結是由 Azure Functions 支援，而非由 WebJobs SDK 支援。

如需 Azure Functions 執行時間所支援的繫結的完整清單，請參閱支援的繫結。

Disable、Timeout 和 Singleton 屬性

透過這些屬性，您可以控制函式觸發程序、取消函式，並確保只會執行一個函式的執行個體。

Disable 屬性

Disable 屬性可讓您控制哪些函式可觸發。

在下列範例中，如果應用程式設定 Disable_TestJob 的值為 1 或 True (不區分大小寫)，該函式將不會執行。在此情況下，執行階段會建立記錄訊息「函式 'Functions.TestJob' 已停用」。

[Disable("Disable_TestJob")]
public static void TestJob([QueueTrigger("testqueue2")] string message)
{
    Console.WriteLine("Function with Disable attribute executed!");
}

當您在 Azure 入口網站中變更應用程式設定值時，會造成 WebJob 重新啟動，並挑選新的設定。

此屬性可在參數、方法或類別等級宣告。設定名稱也可以包含繫結運算式。

Timeout 屬性

Timeout 屬性會在函式未於指定時間內完成時，使函式遭到取消。在下列範例中，函式會執行一整天，而沒有 Timeout 屬性。 Timeout 會造成函式在 15 秒後遭到取消。當 Timeout 屬性的 "throwOnError" 參數設定為 "true" 時，一旦超過逾時，Webjobs SDK 擲回的例外狀況會終止函式叫用。 "throwOnError" 的預設值為 "false"。使用 Timeout 屬性時，預設行為是設定取消權杖來取消函式叫用，但允許叫用無限期執行，直到函式程式碼返回或擲回例外狀況為止。

[Timeout("00:00:15")]
public static async Task TimeoutJob(
    [QueueTrigger("testqueue2")] string message,
    CancellationToken token,
    TextWriter log)
{
    await log.WriteLineAsync("Job starting");
    await Task.Delay(TimeSpan.FromDays(1), token);
    await log.WriteLineAsync("Job completed");
}

您可以在類別或方法層級套用 Timeout 屬性，並可使用 JobHostConfiguration.FunctionTimeout 指定全域逾時。類別層級或方法層級的逾時會覆寫全域逾時。

Singleton 屬性

Singleton 屬性會確保即使主機 Web 應用程式有多個執行個體時，函式仍只有一個執行個體。 Singleton 屬性使用分散式鎖定來確保執行一個執行個體。

在此範例中，ProcessImage 函式在任何指定的時間只會有一個執行個體：

[Singleton]
public static async Task ProcessImage([BlobTrigger("images")] Stream image)
{
     // Process the image.
}

SingletonMode.Listener

某些觸發程序內建並行管理的支援：

QueueTrigger。將 JobHostConfiguration.Queues.BatchSize 設定為 1。
ServiceBusTrigger。將 ServiceBusConfiguration.MessageOptions.MaxConcurrentCalls 設定為 1。
FileTrigger。將 FileProcessor.MaxDegreeOfParallelism 設定為 1。

您可以使用這些設定確保函式在單一執行個體上以單一項目執行。若要確保當 Web 應用程式擴充為多個執行個體時，函式只會有單一執行個體執行，請在該函式上套用接聽程式層級的 Singleton 鎖定 ([Singleton(Mode = SingletonMode.Listener)])。 JobHost 啟動時需要接聽程式鎖定。如果三個擴充的執行個體全部同時啟動，則其中只有一個執行個體會取得鎖定，且只有一個接聽程式會啟動。

注意

若要深入了解 SingletonMode.Function 的運作方式，請參閱這個 GitHub 存放庫。

範圍值

您可以在 singleton 上指定「範圍運算式/值」。運算式/值可確保會序列化特定範圍函式的所有執行。以這種方式實作更細微的鎖定可允許您的函式進行某種層級的平行處理原則，同時根據您的需求序列化其他引動過程。例如，在下列程式碼中，範圍運算式會繫結至傳入訊息的 Region 值。當佇列包含東部、東部和西部區域中的 3 個訊息時，擁有東部區域的訊息會連續執行。具有西部區域的訊息會與東部區域的訊息平行執行。

[Singleton("{Region}")]
public static async Task ProcessWorkItem([QueueTrigger("workitems")] WorkItem workItem)
{
     // Process the work item.
}

public class WorkItem
{
     public int ID { get; set; }
     public string Region { get; set; }
     public int Category { get; set; }
     public string Description { get; set; }
}

SingletonScope.Host

鎖定的預設範圍是 SingletonScope.Function，這表示鎖定範圍 (二進位大型物件租用路徑) 繫結至完整的函式名稱。若要跨函式鎖定，請指定 SingletonScope.Host，而且使用的範圍識別碼名稱在所有您不想要同時執行的函式中皆相同。在下列範例中，一次只有 AddItem 或 RemoveItem 的一個執行個體會執行：

[Singleton("ItemsLock", SingletonScope.Host)]
public static void AddItem([QueueTrigger("add-item")] string message)
{
     // Perform the add operation.
}

[Singleton("ItemsLock", SingletonScope.Host)]
public static void RemoveItem([QueueTrigger("remove-item")] string message)
{
     // Perform the remove operation.
}

檢視租用二進位大型物件

WebJobs SDK 使用 Azure 二進位大型物件租用以實作分散式鎖定。 Singleton 所使用的租用二進位大型物件位在 "locks" 路徑下方，AzureWebJobsStorage 儲存體帳戶中的 azure-webjobs-host 容器中。例如，稍早所示第一個 ProcessImage 範例的租用二進位大型物件路徑可以是 locks/061851c758f04938a4426aa9ab3869c0/WebJobs.Functions.ProcessImage。所有路徑皆包含 JobHost 識別碼，在此個案中為 061851c758f04938a4426aa9ab3869c0。

Async 函數

如需如何將非同步函式編碼的相關資訊，請參閱 Azure Functions 文件。

取消權杖

如需如何處理取消權杖的相關資訊，請參閱取消權杖與順利關機 (英文) 上的 Azure Functions 文件。

多個執行個體

如果您的 Web 應用程式在多個執行個體上執行，則會有一個連續的 WebJob 在每個執行個體上執行，以接聽觸發程序和呼叫函式。各種觸發程序繫結的設計是為了有效地共用在執行個體之間合作的工作，如此便能擴充至更多執行個體，讓您能處理更多負載。

雖然有些觸發程序可能會導致雙重處理，但是佇列和 Blob 儲存體觸發程序會自動防止函式處理佇列訊息或 Blob 超過一次。如需詳細資訊，請參閱 Azure Functions 文件中的設計訴求為進行相同輸入。

計時器觸發程序會自動確保計時器只有一個執行個體會執行，因此在指定的排程時間不會有多個函式正在執行中。

如果您想要確保在即使有多個主機 Web 應用程式執行個體的情況下，仍然只有一個函式執行個體會執行，則您可以使用 Singleton 屬性。

篩選

函式篩選條件 (預覽) 讓您能夠使用自己的邏輯自訂 WebJobs 執行管線。篩選條件與 ASP.NET Core 篩選條件類似。您可以將其實作為套用到函式或類別上的宣告屬性。如需詳細資訊，請參閱函式篩選條件 (英文)。

記錄和監視

我們建議使用針對 ASP.NET 開發的記錄架構。使用者入門一文顯示如何使用。

記錄篩選

ILogger 執行個體建立的每個記錄皆有相關聯的 Category 和 Level。 LogLevel 為一個列舉，而整數代碼表示相對的重要性：

LogLevel	代碼
追蹤	0
偵錯	1
資訊	2
警告	3
錯誤	4
重大	5
無	6

您可以將每個類別個別篩選為特定 LogLevel。例如，您可能想要看見二進位大型物件觸發程序處理的所有記錄，但只看見所有其他項目的 Error 以上等級記錄。

3.x 版

3.x 版的 SDK 相依於內建在 .NET Core 中的篩選條件。 LogCategories 類別可讓您為特定的函式、觸發程序或使用者定義類別。也可為特定的主機狀態定義篩選條件，例如 Startup 和 Results。可讓您微調記錄輸出。如果在已定義的類別內找不到相符項目，則在決定是否篩選訊息時，篩選條件會回復為 Default 值。

LogCategories 需要下列 using 陳述式：

using Microsoft.Azure.WebJobs.Logging;

下列範例建構一個預設會篩選 Warning 層級所有記錄的篩選條件。 Function 或 results 類別 (等同於 2.x 版中的 Host.Results) 會在 Error 層級上篩選。篩選條件會將目前的類別與 LogCategories 執行個體中所有已註冊的層級比較，並選擇最長的相符項目。這表示為 Host.Triggers 註冊的 Debug 層級符合 Host.Triggers.Queue 或 Host.Triggers.Blob。這可讓您控制更廣泛的分類，但無需一一新增。

static async Task Main(string[] args)
{
    var builder = new HostBuilder();
    builder.ConfigureWebJobs(b =>
    {
        b.AddAzureStorageCoreServices();
    });
    builder.ConfigureLogging(logging =>
            {
                logging.SetMinimumLevel(LogLevel.Warning);
                logging.AddFilter("Function", LogLevel.Error);
                logging.AddFilter(LogCategories.CreateFunctionCategory("MySpecificFunctionName"),
                    LogLevel.Debug);
                logging.AddFilter(LogCategories.Results, LogLevel.Error);
                logging.AddFilter("Host.Triggers", LogLevel.Debug);
            });
    var host = builder.Build();
    using (host)
    {
        await host.RunAsync();
    }
}

2.x 版

在 2.x 版的 SDK 中，會使用 LogCategoryFilter 類別來控制篩選。 LogCategoryFilter 具有初始值為 Information 的 Default 屬性，這表示會記錄 Information、Warning、Error 或 Critical 層級的任何訊息，但是 Debug 或 Trace 層級的任何訊息會篩選掉。

如同 3.x 版中的 LogCategories，CategoryLevels 屬性可讓您指定特定類別的記錄層級，以便微調記錄輸出。如果在 CategoryLevels 目錄內找不到相符項目，則當決定是否篩選訊息時，篩選條件會回復到 Default 值。

下列範例建構一個預設會篩選 Warning 等級所有記錄的篩選條件。 Function 和 Host.Results 類別會在 Error 層級篩選。 The LogCategoryFilter 會將目前分類與所有已註冊的 CategoryLevels 比較，並選擇最長的相符項目。因此為 Host.Triggers 註冊的 Debug 層級將符合 Host.Triggers.Queue 或 Host.Triggers.Blob。這可讓您控制更廣泛的分類，但無需一一新增。

var filter = new LogCategoryFilter();
filter.DefaultLevel = LogLevel.Warning;
filter.CategoryLevels[LogCategories.Function] = LogLevel.Error;
filter.CategoryLevels[LogCategories.Results] = LogLevel.Error;
filter.CategoryLevels["Host.Triggers"] = LogLevel.Debug;

config.LoggerFactory = new LoggerFactory()
    .AddApplicationInsights(instrumentationKey, filter.Filter)
    .AddConsole(filter.Filter);

Application Insights 的自訂遙測

針對 Application Insights 實作自訂遙測的程序取決於 SDK 版本。若要了解如何設定 Application Insights，請參閱新增 Application Insights 記錄。

3.x 版

因為 3.x 版的 WebJobs SDK 相依於 .NET Core 泛型主機，所以不再提供自訂遙測資料處理站。但是您可以使用相依性插入將自訂遙測新增至管線。本節中的範例需要下列 using 陳述式：

using Microsoft.ApplicationInsights.Extensibility;
using Microsoft.ApplicationInsights.Channel;

ITelemetryInitializer 的下列自訂實作可讓您將自己的 ITelemetry 新增至預設 TelemetryConfiguration。

internal class CustomTelemetryInitializer : ITelemetryInitializer
{
    public void Initialize(ITelemetry telemetry)
    {
        // Do something with telemetry.
    }
}

在建立器中呼叫 ConfigureServices，以將您的自訂 ITelemetryInitializer 新增至管線。

static async Task Main()
{
    var builder = new HostBuilder();
    builder.ConfigureWebJobs(b =>
    {
        b.AddAzureStorageCoreServices();
    });
    builder.ConfigureLogging((context, b) =>
    {
        // Add logging providers.
        b.AddConsole();

        // If this key exists in any config, use it to enable Application Insights.
        string appInsightsKey = context.Configuration["APPINSIGHTS_INSTRUMENTATIONKEY"];
        if (!string.IsNullOrEmpty(appInsightsKey))
        {
            // This uses the options callback to explicitly set the instrumentation key.
            b.AddApplicationInsights(o => o.InstrumentationKey = appInsightsKey);
        }
    });
    builder.ConfigureServices(services =>
        {
            services.AddSingleton<ITelemetryInitializer, CustomTelemetryInitializer>();
        });
    var host = builder.Build();
    using (host)
    {
        await host.RunAsync();
    }
}

TelemetryConfiguration 建構後，將會納入所有已註冊的 ITelemetryInitializer 類型。若要深入了解，請參閱自訂事件和計量的 Application Insights API。

在 3.x 版中，您不再需要在主機停止時排清 TelemetryClient。 .NET Core 相依性插入系統會自動處置已註冊的 ApplicationInsightsLoggerProvider，而排清 TelemetryClient。

2.x 版

在 2.x 版中，WebJobs SDK 的 Application Insights 提供者內部建立的 TelemetryClient 會使用 ServerTelemetryChannel。當 Application Insights 端點無法使用或正在節流連入要求時，此通道會將要求儲存在 Web 應用程式的檔案系統中，並於稍後重新提交。

TelemetryClient 由實作 ITelemetryClientFactory 的類別所建立。根據預設，這會是 DefaultTelemetryClientFactory。

如果您想要修改 Application Insights 管線的任何一部分，您可以提供自己的 ITelemetryClientFactory，主機將會使用您的類別來建構 TelemetryClient。例如，此程式碼會覆寫 DefaultTelemetryClientFactory 以修改 ServerTelemetryChannel 的屬性：

private class CustomTelemetryClientFactory : DefaultTelemetryClientFactory
{
    public CustomTelemetryClientFactory(string instrumentationKey, Func<string, LogLevel, bool> filter)
        : base(instrumentationKey, new SamplingPercentageEstimatorSettings(), filter)
    {
    }

    protected override ITelemetryChannel CreateTelemetryChannel()
    {
        ServerTelemetryChannel channel = new ServerTelemetryChannel();

        // Change the default from 30 seconds to 15 seconds.
        channel.MaxTelemetryBufferDelay = TimeSpan.FromSeconds(15);

        return channel;
    }
}

SamplingPercentageEstimatorSettings 物件會設定調適型取樣。這表示在某些高容量的情況下，Application Insights 會傳送所選取的遙測資料子集至伺服器。

建立遙測中心之後，您會將其傳遞給 Application Insights 記錄提供者：

var clientFactory = new CustomTelemetryClientFactory(instrumentationKey, filter.Filter);

config.LoggerFactory = new LoggerFactory()
    .AddApplicationInsights(clientFactory);

下一步

本文提供了程式碼片段以示範如何處理使用 WebJobs SDK 的常見案例。如需完整範例，請參閱 azure-webjobs-sdk-samples (英文)。

如何使用 Azure WebJobs SDK 進行事件驅動幕後處理

WebJobs SDK 版本

WebJobs 主機

主機連接字串

主機開發設定

3.x 版

2.x 版

管理並行連線 (2.x 版)

觸發程序

自動觸發程序

手動觸發程序

3.x 版

2.x 版

輸入與輸出繫結

繫結型別

3.x 版

2.x 版

ExecutionContext

3.x 版

2.x 版

繫結設定

Azure Cosmos DB 觸發程序設定 (3.x 版)

事件中樞觸發程序設定 (3.x 版)

佇列儲存體觸發程序設定

3.x 版

2.x 版

SendGrid 繫結設定 (3.x 版)

服務匯流排觸發程序設定 (3.x 版)

其他繫結的設定

3.x 版

2.x 版

繫結運算式

自訂繫結運算式

3.x 版

2.x 版

執行階段的繫結

繫結參考資訊

Disable、Timeout 和 Singleton 屬性

Disable 屬性

Timeout 屬性

Singleton 屬性

SingletonMode.Listener

範圍值

SingletonScope.Host

檢視租用二進位大型物件

Async 函數

取消權杖

多個執行個體

篩選

記錄和監視

記錄篩選

3.x 版

2.x 版

Application Insights 的自訂遙測

3.x 版

2.x 版

下一步

其他資源