Azure Functions の Queue トリガーを .Net 6 と Azure CLI でやってみた

Azure Functions で Azure Storage の Queue をトリガーに並列処理する、イベント駆動型のスケーラブルなアーキテクチャを考えてみます。そもそも Azure Function の Queue トリガーは、キューに入ったメッセージをデフォルトの状態で並列処理してくれるのでしょうか？実際に試してみました。

Azure Functions 検証環境を作成

bash

prefix=mnrfunc
region=japaneast

az group create \
  --name ${prefix}-rg \
  --location $region

az storage account create \
  --name ${prefix}stor \
  --resource-group ${prefix}-rg \
  --sku Standard_LRS

az storage queue create \
  --name myqueue-items \
  --account-name ${prefix}stor

az monitor log-analytics workspace create \
  --workspace-name ${prefix}-log \
  --resource-group ${prefix}-rg

az monitor app-insights component create \
  --app ${prefix}-ai \
  --location $region \
  --resource-group ${prefix}-rg \
  --workspace ${prefix}-log

az functionapp create \
  --name ${prefix} \
  --resource-group ${prefix}-rg \
  --consumption-plan-location $region \
  --runtime dotnet \
  --functions-version 4 \
  --storage-account ${prefix}stor \
  --app-insights ${prefix}-ai \
  --https-only \
  --os-type Linux

検証用アプリを作成

bash

func init $prefix --dotnet

cd $prefix

func new --name queue --template "Queue trigger"

アプリにスリープと終了ログを追加

queue.cs

using System;
using Microsoft.Azure.WebJobs;
using Microsoft.Azure.WebJobs.Host;
using Microsoft.Extensions.Logging;
using System.Threading;

namespace mnrfunc
{
    public class queue
    {
        [FunctionName("queue")]
        public void Run([QueueTrigger("myqueue-items", Connection = "AzureWebJobsStorage")]string myQueueItem, ILogger log)
        {
            log.LogInformation($"C# Queue trigger function processed: {myQueueItem}");
            Thread.Sleep(10000);
            log.LogInformation($"C# Queue trigger function finished: {myQueueItem}");
        }
    }
}

Azure Functions にデプロイ

bash

func azure functionapp publish $prefix

Azure Storage のキューにメッセージを追加

bash

az storage message put \
  --queue-name myqueue-items \
  --content $(echo test | base64) \
  --account-name ${prefix}stor

for i in {1..10}
do
    az storage message put \
    --queue-name myqueue-items \
    --content $(echo test$i | base64) \
    --account-name ${prefix}stor
done

スクショを取り忘れましたが、無事並列処理している事を確認できました。

参考