Microsoft Azure WebJobs SDK の 1.0.0 RTM を発表

Artikel
11/09/2014

このポストは、10 月 25 日に投稿された Announcing the 1.0.0 RTM of Microsoft Azure WebJobs SDK の翻訳です。

このリリースをダウンロードする

この SDK は、Visual Studio 2013 Update 4 RC に同梱されている Azure WebJobs プロジェクトテンプレートにプレインストールされています。

WebJobs SDK は、NuGet のギャラリーからダウンロードできます。NuGet ギャラリーで NuGet Package Manager Console を使用して、パッケージをインストールします。

Install-Package Microsoft.Azure.WebJobs

Microsoft Azure Service Bus のトリガーを使用したい場合は、次のパッケージをインストールします。

Install-Package Microsoft.Azure.WebJobs.ServiceBus

WebJobs SDK とは

Microsoft Azure Websites の WebJobs は、サービスやバックグラウンドタスクなどのプログラムを Websites で簡単に実行できるようにするための機能で、.exe、.cmd、.bat などの各種実行形式ファイルを Websites にアップロードしたり、実行したりすることができると同時に、WebJobs としてトリガーで実行したり継続的に実行したりすることができます。WebJobs SDK なしでバックグラウンドタスクの接続や実行を行うとなると、複雑で膨大な量のプログラミングが必要になりますが、SDK が提供するフレームワークを使用すれば、最低限の量のコードで一般的なタスクを実行することが可能になります。

WebJobs SDK のバインディングシステムとトリガーシステムは、Service Bus だけでなく、Microsoft Azure Storage サービスの BLOB、Queue、Table にも対応しています。バインディングシステムでは、Microsoft Azure Storage オブジェクトを読み込んだり書き込んだりするコードを簡単に作成できます。トリガーシステムは、Queue または BLOB が新しいデータを受信するたびに、コードに記述されている関数を呼び出します。

WebJobs SDK のシナリオ

Azure WebJobs SDK を使用すると容易に対応できる、代表的なシナリオをいくつか紹介します。

画像処理などの CPU 負荷の高い作業。
電子メール送信など、バックグラウンドのスレッドで実行する処理に長い時間がかかるタスク。このようなタスクは、アプリケーションが一定時間以上アイドル状態だと IIS がアプリケーションをリサイクルするため、従来は ASP.NET では不可能でした。しかし、Azure Websites に Always On (英語) (翻訳 - SATO NAOKI ブログ: Web サイト向けのステージング発行のサポート、監視の改善、Hyper-V Recovery Manager の GA、PCI コンプライアンス) が導入されたため、アイドル状態でも Websites のリサイクルを防げるようになりました。Always On (英語) (翻訳 - SATO NAOKI ブログ: Web サイト向けのステージング発行のサポート、監視の改善、Hyper-V Recovery Manager の GA、PCI コンプライアンス) は、サイトがスリープ状態にならないように維持することができるため、処理に長い時間がかかるタスクやサービスを WebJobs や WebJobs SDK で実行できます。
Queue の処理。Web のフロントエンドサービスとバックエンドサービスの通信には Queue を使用するのが一般的です。よくある Producer-Consumer パターンの 1 つです。
RSS 情報集約。RSS フィードのリストを保持するサイトを所有している場合、バックグラウンドプロセスでフィードからすべての記事を取得することがあります。
ファイルのメンテナンス。ログファイルの集約や整理など。
受信処理。CSV リーダー、ログの解析、Table へのデータの格納など。

SDK の目的

Azure Storage を使用してバックグラウンド処理を容易に行えるようにする手段を提供すること。
Azure Storage との連携を容易にすること。SDK を利用すれば、ストレージからのデータの読み書きを行うコードを作成する必要はありません。
診断やログ出力用のコードを開発することなく使用できる、リッチな診断機能と監視機能を提供すること。

SDK の機能

トリガー

Queue または BLOB で新たな入力が検出されると、関数が実行されます。

バインディング機能

この SDK ではバインディング機能がサポートされており、C# プリミティブ型と、BLOB、Table、Queue、Service Bus といった Azure Storage の間でモデルバインディングを行います。これにより、BLOB、Table、Queue からデータを読み書きする処理が簡単になります。これには、次のようなメリットがあります。

利便性: 最も使いやすい型を選択すると、WebJobs SDK がグルーコードとして働きます。BLOB で文字列操作を行う場合、TextWriter への変換方法を気にすることなく、直接 TextReader および TextWriter にバインドできます。
フラッシュとクローズ: WebJobs SDK は、未処理の出力を自動的にフラッシュおよびクローズします。
ユニットテストが可能: この SDK は、ICloudBlob などではなく TextWriter などのプリミティブ型のモックとして動作させることができるため、作成したコードのユニットテストが可能です。
診断機能: ダッシュボードから使用可能なモデルバインディング機能により、パラメーターの使用状況をリアルタイムで診断できます。

現在 Stream 、 TextReader/Writer 、 String のバインディングがサポートされています。カスタム型や Storage SDK のその他の型へのバインディングのサポートを追加することが可能です。

Azure Queues

SDK を使用して、Queue に新しいメッセージが送信された場合に関数をトリガーすることができます。String、Poco (Plain old CLR object)、byte[]、Azure Storage SDK の各型にバインディングすることにより、メッセージの内容に簡単にアクセスできます。次に、Queue で使用できるその他の主要な機能を紹介します。

詳細については、0.5.0-beta、0.4.0-beta、0.3.0-beta の発表記事を参照してください。

関数をトリガーして、メッセージの内容を String, Poco (Plain old CLR object)、byte[]、CloudQueueMessage にバインディングします。
単一または複数のメッセージを Queue に送信します。
Queue の並列実行: 1 つの QueueTrigger 内で、並行して Queue の複数のメッセージがフェッチされます。つまり、関数が Queue をリッスンしている場合、この Queue に対して 16 個 (既定値) の Queue のメッセージのバッチが並行して取得されます。また、関数も並行して実行されます。
Azure Queues の有害メッセージの処理
Queue の DequeueCount プロパティへのアクセス
Azure Queues のポーリングロジックの改良: ストレージのトランザクションコストに対するアイドル時の Queue のポーリングの影響を減らすために、SDK にはランダムな指数バックオフアルゴリズムが実装されています。
高速なパスの通知: SDK を使用して複数の Queue にメッセージを送信する場合、SDK によってメッセージの高速追跡が実行されます。
Queue のポーリングの構成オプション: Queue のポーリング動作を構成できるように、数点のオプションが用意されています。
- MaxPollingInterval は、Queue が空の状態が続く場合に、メッセージを確認するまでに待機する最長の時間を指定するために使用します。既定値は 1 分です。
- MaxDequeueCount は、Queue のメッセージを有害な Queue に移動するタイミングを指定するために使用します。既定値は 5 です。

Azure Blobs

SDK を使用して、新しい BLOB が検出された場合や、既存の BLOB が更新された場合に、関数をトリガーすることができます。Stream、String、Poco (Plain old CLR object)、byte[]、TextReader、TextWriter、Azure Storage SDK の各型にバインディングすることにより、BLOB の内容にアクセスできます。

詳細については、0.5.0-beta、0.4.0-beta、0.3.0-beta の発表記事を参照してください。

BlobTrigger は、新しい BLOB が検出された場合または既存の BLOB が更新された場合にのみトリガーされます。
BLOB の再試行およびエラー処理: BLOB の処理時にエラーが発生した場合に、関数の再試行がサポートされています。BlobTrigger では、指定した回数の上限に達するまで処理を再試行します (既定値は 5 回)。しきい値に達して関数が 5 回実行されると、「webjobs-blobtrigger-poison」という Queue にメッセージが送信されます。この Queue の QueueTrigger を使用して関数をトリガーし、メッセージに対してカスタムのエラー処理を実行することができます。

Azure Storage Tables

SDK を使用して、Table にバインディングし、読み取り、書き込み、更新、削除の操作を実行することができます。

詳細については、0.6.0-beta (英語) (翻訳 - SATO NAOKI ブログ: Microsoft Azure WebJobs SDK の 0.6.0-beta プレビューの発表)、0.5.0-beta、0.4.0-beta、0.3.0-beta の発表記事を参照してください。

受信処理は、BLOB に格納されたファイルを解析し、値を CSV リーダーなどの Table に格納する場合の一般的なシナリオです。このような場合、Ingress 関数によって多数の行 (場合によっては何百万もの行) が書き込まれる可能性があります。

WebJobs SDK では、この機能を簡単に実装し、Table に書き込まれた行数などをリアルタイムで監視する機能を追加することができるため、Ingress 関数の進捗状況を監視することができます。

Azure Service Bus

Azure Queues と同様に、SDK を使用して、新しいメッセージが Service Bus Queue またはトピックに送信された場合に関数をトリガーすることができます。String、Poco (Plain old CLR object)、byte[]、BrokeredMessage にバインディングすることにより、メッセージの内容に簡単にアクセスできます。

詳細については、0.3.0-beta の発表記事を参照してください。

全般

次に、SDK のその他の機能の一部を紹介します。

非同期のサポート: async 関数がサポートされています。
CancellationToken: 関数に CancellationToken パラメーターを使用して、ホストからキャンセルのリクエストを受信できます。
NameResolver: SDK の拡張レイヤーでは、Queue 名または BLOB 名のソースを指定することができます。たとえば、この機能を使用して、構成ファイルから Queue 名を取得できます。こちらのサンプル (英語) をご覧ください。
WebJobs シャットダウン通知 : WebJobs の正常なシャットダウン (Graceful Shutdown、英語) 通知機能では、WebJobs が停止するときに通知が表示されます。SDK は WebJobs がシャットダウンするタイミングをユーザーに通知することで、WebJobs の正常なシャットダウンをサポートします。この情報は CancellationToken により関数に伝えられます。次の関数は、WebJobs が停止すると CancellationToken を通じてキャンセルのリクエストを受信します。

 public static void UseCancellationToken(
    [QueueTrigger("inputqueue")] string inputText,
    TextWriter log,
    CancellationToken token)
{
// 長い時間がかかる関数をキャンセルすることが可能  
      while (!token.IsCancellationRequested)
      {
          Thread.Sleep(2000);
          log.WriteLine("Not cancelled");
      }
      log.WriteLine("cancelled");
}

WebJobs の監視用ダッシュボード

WebJobs の実行中は、リアルタイムの監視が可能です。このため、WebJobs の状態 (Running、Stopped、Successfully completed)、最終実行日時、実行ログを確認できます。次の画面で Websites で稼動するすべての WebJobs を確認できます。

この SDK を使用して WebJobs を作成すると、プログラム内の関数の診断と監視を行えます。ここで、画像処理を行う「ImageResizeAndWaterMark」という名前の WebJobs を作成した場合について考えます。フローは次のようになります。

まず、ユーザーが画像を BLOB の「images-input」というコンテナーにアップロードすると、Resize 関数がトリガーされます。Resize はこの画像を処理した後に「images2-output」コンテナーに書き込みます。ここで Watermark 関数がトリガーされ、画像のサイズ変更が実行された後に「images3-output」という BLOB コンテナーに書き込まれます。次のコードは、上記で説明した WebJobs を示しています。

 public class ImageProcessing
    {
        public static void Resize(
            [BlobTrigger(@"images-input/{name}")] WebImage input,
            [Blob(@"images2-output/{name}")] out WebImage output)
        {
            var width = 80;
            var height = 80;
            output = input.Resize(width, height);
        }

        public static void WaterMark(
            [BlobTrigger(@"images2-output/{name}")] WebImage input,
            [Blob(@"image3-output/{name}")] out WebImage output)
        {
            output = input.AddTextWatermark("WebJobs", fontSize: 6);
        }
    }

    public class WebImageBinder : ICloudBlobStreamBinder<WebImage>
    {
        public Task<WebImage> ReadFromStreamAsync(Stream input, System.Threading.CancellationToken cancellationToken)
        {
            return Task.FromResult<WebImage>(new WebImage(input));
        }

        public Task WriteToStreamAsync(WebImage value, Stream output, System.Threading.CancellationToken cancellationToken)
        {
            var bytes = value.GetBytes();
            return output.WriteAsync(bytes, 0, bytes.Length);
        }
    }

WebJobs を Azure で実行しているときに Microsoft Azure Websites のポータルで [WEBJOBS] タブの「ImageResizeAndWaterMark」というログへのリンクをクリックすると、WebJobs のダッシュボードが表示されます。

ダッシュボードは SiteExtension なので、https://<自身のサイト>.scm.azurewebsites.net/azurejobs という URL でアクセスできます。SiteExtension にアクセスするには、デプロイメントの認証情報が必要です。SiteExtension へのアクセスの詳細については、Kudu プロジェクトのドキュメントをお読みください。
https://github.com/projectkudu/kudu/wiki/Accessing-the-kudu-service (英語)

関数実行の詳細

「ImageResizeAndWaterMark」という WebJobs の実行を監視する場合、プログラム内の関数呼び出しに関する次のような詳細情報を確認できます。

関数のパラメーターの種類
関数の実行時間
BLOB からの読み込みの所要時間と読み書きのバイト数

呼び出しと再実行

上の例では、WaterMark 関数が何らかの理由で正常に動作しない場合、新しい画像をアップロードして WaterMark 関数を再実行すると、実行チェーンがトリガーされ、Resize 関数が呼び出されます。これは、関数どうしが複雑に組み合わされている場合に問題を診断してデバッグするのに便利です。また、ダッシュボードからも関数を呼び出すことができます。

関数の因果関係

上の例では、WaterMark 関数が BLOB への書き込みを行うと、Resize 関数がトリガーされます。ダッシュボードでは、この関数の因果関係が表示されます。多数の関数が複雑に絡み合い、新しい入力が検出されるたびにトリガーされるような場合に、この因果関係グラフが役立ちます。

BLOB の検索

[Search Blobs] をクリックし BLOB を検索すると、該当する BLOB で発生した事象に関する情報を確認できます。たとえば、ImageResizeAndWaterMark の場合は WaterMark 関数が実行されると、BLOB に対する書き込みが行われます。BLOB の検索の詳細については、こちらの記事 (英語) を参照してください。

サンプル

WebJobs SDK のサンプルについては、次のページをご覧ください。
https://github.com/Azure/azure-webjobs-sdk-samples (英語)

BLOB、Table、Queue、および Service Bus でのトリガーやバインディングの使用例をご覧いただけます。
PhluffyShuffy という画像処理 Websites では、ユーザーが写真をアップロードすると、BLOB ストレージのその画像を処理する関数がトリガーされます。
PhluffyLogs というサンプルでは、WebJobs が、アプリケーションによって生成されたログファイルを解析し、ログファイルをアーカイブします。

SDK を使用した Azure Websites への WebJobs のデプロイ

Visual Studio 2013 Update 3 と Azure SDK 2.4 では、WebJobs を Azure Websites に発行する Visual Studio ツールがサポートされています。詳細については、Azure Websites への Azure WebJobs のデプロイ方法 (英語) を参照してください。

フィードバックとヘルプについて

ご質問は、Azure フォーラム、ASP.NET のフォーラム (英語)、または StackOverflow.com (英語) までお寄せください。Twitter の場合は #AzureWebJobs SDK を付けてフィードバックをお願いします。StackOverflow では Azure-WebJobsSDK タグをご使用ください。

Freigeben über