2
2

Delete article

Deleted articles cannot be recovered.

Draft of this article would be also deleted.

Are you sure you want to delete this article?

More than 3 years have passed since last update.

新 Azure Functions 拡張ライブラリの紹介 (ベータ版)

Last updated at Posted at 2021-05-31

みなさんごきげんよう。本記事は、2021 年 5 月 28 日(米国時間)ポストされた https://devblogs.microsoft.com/azure-sdk/introducing-the-new-azure-function-extension-libraries-beta/ の意訳(と、ちょっと手を加えたもの)となります。
内容については下記原文が正となります。


最新 (訳注 : 2021/05/31 現在) Azure SDK のガイドライン に沿って作成された、Storage (5.0.0-beta.4) 、Event Hubs (5.0.0-beta.5)、Service Bus (5.0.0-beta.3)、Event Grid (3.0.0-beta.2) の Functions 拡張ライブラリのベータ版をリリースしました。

本稿では、これらのライブラリの新機能のいくつかに触れていこうと思います。一般提供 (GA) 開始までにこれらのライブラリをお試しいただけるととてもうれしいです。お試しいただいた結果のフィードバックなどお寄せいただけると、泣いて喜びますので是非よろしくお願いいたします…!!

新機能

シークレットレス構成

Storage、Event Hubs、Service Bus の各拡張機能は、Azure Active Directory を介したシークレットレス構成をサポートするようになりました。これにより、関数アプリは、設定の一部として接続文字列を提供することなく、これらのサービスで認証が可能になります。
ここでは、ポータル内の関数アプリのアプリケーション [設定] セクションで、各ライブラリに対してどのような設定を行うかを説明します。関数アプリのアプリケーション設定の詳細については、以下をご覧ください。

ローカル環境で実行する場合も、local.settings.json ファイルを修正することにより同様の設定が可能です。

なお、ローカル環境でシークレットレス設定を使用すると local.settings.json ファイルに接続文字列がないという旨の警告が表示されることがありますが、この点については拡張機能の一般提供開始前に修正される予定です。

一般的な設定

ここで説明するすべての拡張機能では、AzureWebJobsStorage の設定で、汎用ストレージ アカウントを使用するように設定する必要があります。

|Name |Value |
|---|---|---|
|AzureWebJobsStorage__accountName |{アカウント名} |

ローカル開発の場合は、AzureWebJobsStorage の値を UseDevelopmentStorage=true に設定することで、Azurite エミュレータ を使用することができます。

特に指定のない限り、各構成は DefaultAzureCredential で動作します。これは、関数アプリ(またはローカルで実行している場合はローカル環境)が、DefaultAzureCredential で使用される認証メカニズムの少なくとも 1 つを用いて、対応するストレージ アカウント、Event Hubs 名前空間、または Service Bus 名前空間で認証できる必要があるということを意味します。

ストレージ

Blob

|Name |Value |
|---|---|---|
|MyConnection__blobServiceUri|https://{アカウント名}.blob.core.windows.net|

以下は、指定した blob が変更されるたびに実行されるシンプルな関数の例です。

[FunctionName("BlobTriggerFunction")]
public static void Run(
    [BlobTrigger("sample-container/sample-blob", Connection = "MyConnection")]
    Stream blobStream,
    ILogger logger)
{
    using var blobStreamReader = new StreamReader(blobStream);
    logger.LogInformation($"Blob sample-container/sample-blob has been updated with content: {blobStreamReader.ReadToEnd()}");
}

キュー

|Name |Value |
|---|---|---|
|MyConnection__queueServiceUri|https://{アカウント名}.queue.core.windows.net|

以下は、指定されたキューにメッセージが配信されるたびに実行されるシンプルな関数の例となります。

[FunctionName("QueueTriggerFunction")]
public static void Run(
    [QueueTrigger("sample-queue", Connection = "MyConnection")] 
    string message,
    ILogger logger)
    {
        logger.LogInformation($"Received message from sample-queue, content={message}");
    }

Event Hubs

|Name |Value |
|---|---|---|
|MyConnection__fullyQualifiedNamespace|https://{アカウント名}.servicebus.windows.net|

以下は、指定された Event Hubs にイベントが配信されるたびに実行されるシンプルな関数の例となります。

[FunctionName("EventHubTriggerFunction")]
public static void Run(
    [EventHubTrigger("<event_hub_name>", Connection = "MyConnection")]
    EventData eventData,
    ILogger logger)
{
    logger.LogInformation($"C# function triggered to process a message: {eventData.EventBody}");
    logger.LogInformation($"EnqueuedTime={eventData.EnqueuedTime}");
}

Service Bus

|Name |Value |
|---|---|---|
|MyConnection__fullyQualifiedNamespace|https://{アカウント名}.servicebus.windows.net|

以下は、指定されたキューにメッセージが配信されるたびに実行されるシンプルな関数の例になります。

[FunctionName("ServiceBusTriggerFunction")]
public static void Run(
    [ServiceBusTrigger("<queue_name>", Connection = "MyConnection")]
    ServiceBusReceivedMessage message,
    ILogger logger)
{
    logger.LogInformation($"C# function triggered to process a message: {message.Body}");
    logger.LogInformation($"EnqueuedTime={message.EnqueuedTime}");
}

より詳細な機能を構成する

これまで触れてきた例では、拡張機能に DefaultAzureCredential を用いて、サービスとの認証を試行していましたが、もちろん、より詳細に認証を設定することも可能です。以下、Blob Storage を例に、Storage Queues、Event Hubs、Service Bus でも同様の設定を行う例です。ManagedIdentityCredential を使用するマネージド ID を使って設定するには、次のようにします。

|Name |Value |
|---|---|---|
|MyConnection__blobServiceUri|https://{account name}.blob.core.windows.net|
|MyConnection__credential|マネージド ID|
|MyConnection__clientId|{myClientId}|

ClientSecretCredential タイプを使用するクライアント シークレット資格情報を使用して設定するには、次のようにします。

|Name |Value |
|---|---|---|
|MyConnection__blobServiceUri|https://{account name}.blob.core.windows.net|
|MyConnection__tenantId|{myTenantId}|
|MyConnection__clientId|{myClientId}|
|MyConnection__clientSecret|{myClientSecret}|

最後に、クライアント証明書を使用して設定するには、ClientSecretCredential タイプを使用するようにします。

|Name |Value |
|---|---|---|
|MyConnection__blobServiceUri|https://{account name}.blob.core.windows.net|
|MyConnection__tenantId|{myTenantId}|
|MyConnection__clientId|{myClientId}|
|MyConnection__certificate|{myCertificate}|

CloudEvent バインディング

C# で関数を記述する際に、CloudEvents V1 スキーマに準拠した新しいCloudEvent タイプを、トリガーと出力の両方の関数に使用することが可能になりました。

トリガー :

[FunctionName("CloudEventTriggerFunction")]
public static void Run(
    [EventGridTrigger]
    CloudEvent e,
    ILogger logger,)
{
    logger.LogInformation("Event received {type} {subject}", e.Type, e.Subject);
}

出力 :

[FunctionName("CloudEventBindingFunction")]
public static async Task<IActionResult> RunAsync(
    [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post", Route = null)]
    HttpRequest req,
    [EventGrid(TopicEndpointUri = "EventGridEndpoint", TopicKeySetting = "EventGridKey")]
    IAsyncCollector<CloudEvent> eventCollector)
{
    CloudEvent e = new CloudEvent("IncomingRequest", "IncomingRequest", await req.ReadAsStringAsync());
    await eventCollector.AddAsync(e);
    return new OkResult();
}

むすび

Azure Functions は、Azure の中核となるサーバーレス製品の 1 つで、アプリケーションを大幅に簡素化することができます。最新のパッケージ セットは、Azure Functions との統合を迅速かつ容易にすすめ、アプリケーションを迅速に立ち上げられるようにするための我々の取り組みの一環です。

この記事で紹介した拡張機能の詳細については、各サービスの README ファイルをご覧くださいませ。(訳注 : 先の README は英語です)

Azure SDK の Blog 寄稿募集してます!

この記事を読んでいただきありがとうございます。何か新しい学びの一助になったらいいなと願っています。また、私たちは、Azure SDK ブログの記事の寄稿を歓迎しております。azsdkblog@microsoft.com までご連絡いただければ、ゲストブロガーとして設定させていただきます。
(訳注 : おそらく英語で…だとおもいますがぜひ!我こそは!という方はよろしくお願いします。)

Azure SDK のリンクたち


以上、Josh Love さんからでした。

それでは皆さん、ごきげんよう。

2
2
0

Register as a new user and use Qiita more conveniently

  1. You get articles that match your needs
  2. You can efficiently read back useful information
  3. You can use dark theme
What you can do with signing up
2
2

Delete article

Deleted articles cannot be recovered.

Draft of this article would be also deleted.

Are you sure you want to delete this article?