Azure Functions の Azure Event Grid トリガー

[アーティクル]
11/24/2023

関数トリガーを使用して、Event Grid ソースによって送信されたイベントに応答します。イベントを受信するには、ソースへのイベントサブスクリプションが必要です。イベントサブスクリプションを作成する方法については、サブスクリプションの作成に関するセクションを参照してください。バインドの設定と構成の詳細については、概要に関するページを参照してください。

Note

Event Grid トリガーは、内部ロードバランサーの App Service Environment (ASE) ではネイティブにサポートされません。このトリガーで使用される HTTP 要求は、仮想ネットワークへのゲートウェイなしでは関数アプリに届きません。

重要

この記事では、タブを使用して、Node.js プログラミングモデルの複数のバージョンに対応しています。 v4 モデルは一般提供されており、JavaScript と TypeScript の開発者にとって、より柔軟で直感的なエクスペリエンスが得られるように設計されています。 v4 モデルの動作の詳細については、Azure Functions Node.js 開発者ガイドを参照してください。 v3 と v4 の違いの詳細については、移行ガイドを参照してください。

Azure Functions では、Python の 2 つのプログラミングモデルがサポートされています。バインドを定義する方法は、選択したプログラミングモデルによって異なります。

Python v2 プログラミングモデルでは、Python 関数コードでデコレーターを使用してバインドを直接定義できます。詳細については、「Python 開発者ガイド」を参照してください。

この記事は、両方のプログラミングモデルをサポートしています。

例

HTTP トリガーの例については、「HTTP エンドポイントへのイベントの受信」を参照してください。

Event Grid トリガーで使われる入力パラメーターの型は、次の 3 つの要因で変わります。

Functions ランタイムのバージョン
バインド拡張機能のバージョン
C# 関数のモダリティ。

A C# 関数は、次の C# モードのいずれかを使用して作成できます。

分離されたワーカーモデル: ランタイムから分離されたワーカープロセスで実行されるコンパイル済みの C# 関数。分離ワーカープロセスは、LTS および非 LTS バージョンの .NET および .NET Framework で実行されている C# 関数をサポートするために必要です。分離ワーカープロセス関数の拡張機能では、Microsoft.Azure.Functions.Worker.Extensions.* 名前空間が使用されます。
インプロセスモデル: Functions ランタイムと同じプロセスで実行されるコンパイル済みの C# 関数。このモデルの一部では、主に C# ポータルの編集のためにサポートされている C# スクリプトを使用して Functions を実行できます。インプロセス関数の拡張機能では、Microsoft.Azure.WebJobs.Extensions.* 名前空間が使用されます。

重要

インプロセスモデルのサポートは 2026 年 11 月 10 日に終了します。完全なサポートのために、分離ワーカーモデルにアプリを移行することを強くお勧めします。

分離ワーカーモデル
インプロセスモデル

C# 関数を分離ワーカープロセスで実行する場合、イベントプロパティにカスタムの型を定義する必要があります。次の例では、MyEventType クラスを定義しています。


        public string? Topic { get; set; }

        public string? Subject { get; set; }

        public string? EventType { get; set; }

        public DateTime EventTime { get; set; }

        public IDictionary<string, object>? Data { get; set; }
    }
}

次の例は、トリガーと Event Grid 出力バインディングの両方でカスタム型がどのように使用されるかを示しています。

    [Function(nameof(EventGridFunction))]
    [EventGridOutput(TopicEndpointUri = "MyEventGridTopicUriSetting", TopicKeySetting = "MyEventGridTopicKeySetting")]
    public static MyEventType Run([EventGridTrigger] MyEventType input, FunctionContext context)
    {
        var logger = context.GetLogger(nameof(EventGridFunction));
        logger.LogInformation(input.Data?.ToString());

        var outputEvent = new MyEventType()
        {
            Id = "unique-id",
            Subject = "abc-subject",
            Data = new Dictionary<string, object>
            {
                { "myKey", "myValue" }
            }
        };

        return outputEvent;
    }
}

public class MyEventType
{

次の例は、CloudEvent バインドパラメーターを使う Functions バージョン 4.x 関数を示しています。

using Azure.Messaging;
using Microsoft.Azure.WebJobs;
using Microsoft.Azure.WebJobs.Extensions.EventGrid;
using Microsoft.Extensions.Logging;

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

次の例は、EventGridEvent バインドパラメーターを使う Functions バージョン 4.x 関数を示しています。

using Microsoft.Azure.WebJobs;
using Azure.Messaging.EventGrid;
using Microsoft.Azure.WebJobs.Extensions.EventGrid;
using Microsoft.Extensions.Logging;

namespace Company.Function
{
    public static class EventGridTriggerDemo
    {
        [FunctionName("EventGridTriggerDemo")]
        public static void Run([EventGridTrigger] EventGridEvent eventGridEvent, ILogger log)
        {
            log.LogInformation(eventGridEvent.Data.ToString());
        }
    }
}

次の例は、JObject バインドパラメーターを使う関数を示しています。

using Microsoft.Azure.WebJobs;
using Microsoft.Azure.WebJobs.Extensions.EventGrid;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using Microsoft.Extensions.Logging;

namespace Company.Function
{
    public static class EventGridTriggerCSharp
    {
        [FunctionName("EventGridTriggerCSharp")]
        public static void Run([EventGridTrigger] JObject eventGridEvent, ILogger log)
        {
            log.LogInformation(eventGridEvent.ToString(Formatting.Indented));
        }
    }
}

このセクションには、次の例が含まれています。

Event Grid グリッドトリガー、文字列パラメーター
Event Grid グリッドトリガー、POJO パラメーター

次の例は、バインドを使用してイベントを生成する Java のトリガーバインドを示しています。最初の例ではイベントを String として受け取り、2 番目の例では POJO として受け取ります。

Event Grid グリッドトリガー、文字列パラメーター

  @FunctionName("eventGridMonitorString")
  public void logEvent(
    @EventGridTrigger(
      name = "event"
    )
    String content,
    final ExecutionContext context) {
      context.getLogger().info("Event content: " + content);
  }

Event Grid グリッドトリガー、POJO パラメーター

この例では、次の POJO が使用されています。Event Grid イベントの最上位プロパティを表します。

import java.util.Date;
import java.util.Map;

public class EventSchema {

  public String topic;
  public String subject;
  public String eventType;
  public Date eventTime;
  public String id;
  public String dataVersion;
  public String metadataVersion;
  public Map<String, Object> data;

}

受け取り時、イベントの JSON ペイロードが EventSchema POJO に逆シリアル化され、関数で使用されます。このプロセスにより、関数はオブジェクト指向でイベントのプロパティにアクセスできます。

  @FunctionName("eventGridMonitor")
  public void logEvent(
    @EventGridTrigger(
      name = "event"
    )
    EventSchema event,
    final ExecutionContext context) {
      context.getLogger().info("Event content: ");
      context.getLogger().info("Subject: " + event.subject);
      context.getLogger().info("Time: " + event.eventTime); // automatically converted to Date by the runtime
      context.getLogger().info("Id: " + event.id);
      context.getLogger().info("Data: " + event.data);
  }

Java 関数ランタイムライブラリで、その値が Event Grid に由来するパラメーター上で EventGridTrigger 注釈を使用します。これらの注釈を使用したパラメーターによって、イベントを受信したときに関数が実行されます。この注釈は、Java のネイティブ型、POJO、または Optional<T> を使用した null 許容値で使用できます。

モデル v4
モデル v3

次の例は、イベントグリッドトリガーの TypeScript 関数を示しています。

import { app, EventGridEvent, InvocationContext } from '@azure/functions';

export async function eventGridTrigger1(event: EventGridEvent, context: InvocationContext): Promise<void> {
    context.log('Event grid function processed event:', event);
}

app.eventGrid('eventGridTrigger1', {
    handler: eventGridTrigger1,
});

モデル v4
モデル v3

次の例は、イベントグリッドトリガーの JavaScript 関数を示しています。

const { app } = require('@azure/functions');

app.eventGrid('eventGridTrigger1', {
    handler: (event, context) => {
        context.log('Event grid function processed event:', event);
    },
});

次の例は、function.json ファイルのトリガーバインドと、そのバインドを使用する JavaScript 関数を示しています。

function.json ファイルのバインディングデータを次に示します。

{
  "bindings": [
    {
      "type": "eventGridTrigger",
      "name": "eventGridEvent",
      "direction": "in"
    }
  ],
  "disabled": false
}

JavaScript コードを次に示します。

module.exports = async function (context, eventGridEvent) {
    context.log("JavaScript Event Grid function processed a request.");
    context.log("Subject: " + eventGridEvent.subject);
    context.log("Time: " + eventGridEvent.eventTime);
    context.log("Data: " + JSON.stringify(eventGridEvent.data));
};

次の例は、function.json ファイルで Event Grid トリガーバインドを構成する方法を示しています。

{
  "bindings": [
    {
      "type": "eventGridTrigger",
      "name": "eventGridEvent",
      "direction": "in"
    }
  ]
}

Event Grid イベントは、次の PowerShell の例に示すように、eventGridEvent という名前のパラメーターを使用して関数で使用できるようになります。

param($eventGridEvent, $TriggerMetadata)

# Make sure to pass hashtables to Out-String so they're logged correctly
$eventGridEvent | Out-String | Write-Host

次の例は、Event Grid トリガーバインドと、そのバインドが使用される Python 関数を示しています。この例は、v1 と v2 のどちらの Python プログラミングモデルを使用するかによって異なります。

import logging
import json
import azure.functions as func

app = func.FunctionApp()

@app.function_name(name="eventGridTrigger")
@app.event_grid_trigger(arg_name="event")
def eventGridTest(event: func.EventGridEvent):
    result = json.dumps({
        'id': event.id,
        'data': event.get_json(),
        'topic': event.topic,
        'subject': event.subject,
        'event_type': event.event_type,
    })

    logging.info('Python EventGrid trigger processed an event: %s', result)

function.json ファイルのバインディングデータを次に示します。

{
  "bindings": [
    {
      "type": "eventGridTrigger",
      "name": "event",
      "direction": "in"
    }
  ],
  "disabled": false,
  "scriptFile": "__init__.py"
}

Python コードを次に示します。

import json
import logging

import azure.functions as func

def main(event: func.EventGridEvent):

    result = json.dumps({
        'id': event.id,
        'data': event.get_json(),
        'topic': event.topic,
        'subject': event.subject,
        'event_type': event.event_type,
    })

    logging.info('Python EventGrid trigger processed an event: %s', result)

属性

インプロセスと分離ワーカープロセスの両方の C# ライブラリで、EventGridTrigger 属性が使用されます。 C# スクリプトでは、C# スクリプトガイドで説明されているように、代わりに function.json 構成ファイルを使用します。

分離ワーカーモデル
インプロセスモデル

メソッドシグネチャでの EventGridTrigger 属性を次に示します。

public static MyEventType Run([EventGridTrigger] MyEventType input, FunctionContext context)
{
    var logger = context.GetLogger(nameof(EventGridFunction));
    logger.LogInformation(input.Data?.ToString());

メソッドシグネチャでの EventGridTrigger 属性を次に示します。

[FunctionName("EventGridTest")]
public static void EventGridTest([EventGridTrigger] JObject eventGridEvent, ILogger log)
{

注釈

EventGridTrigger 注釈を使用すると、構成値を指定して、Event Grid のバインディングを宣言によって構成できます。詳細については、例と構成に関するセクションを参照してください。

app.eventGrid() メソッドに渡される options オブジェクトは、現在、モデル v4 のどのプロパティもサポートしていません。

次の表は、function.json ファイルで設定したバインド構成のプロパティを説明しています。

プロパティ	説明
type	必須 - `eventGridTrigger` に設定する必要があります。
direction	必須 - `in` に設定する必要があります。
name	必須 - イベントデータを受信するパラメーターの、関数コードで使われている変数名。

構成

次の表は、function.json ファイルで設定したバインド構成のプロパティを説明しています。 EventGridTrigger 属性で設定するコンストラクターパラメーターまたはプロパティはありません。

function.json のプロパティ	説明
type	必須 - `eventGridTrigger` に設定する必要があります。
direction	必須 - `in` に設定する必要があります。
name	必須 - イベントデータを受信するパラメーターの、関数コードで使われている変数名。

完全な例については、セクションの例を参照してください。

使用方法

Event Grid トリガーは Webhook HTTP 要求を使用します。これは、HTTP トリガーと同じ host.json 設定を使用して構成できます。

Event Grid トリガーによってサポートされるパラメーター型は、Functions ランタイムのバージョン、拡張機能パッケージのバージョン、および使用される C# のモダリティによって異なります。

関数で 1 つのイベントを処理するとき、Event Grid トリガーは次の種類にバインドできます。

Type	説明
JSON シリアル化可能な型	Functions はイベントの JSON データを Plain Old CLR Object (POCO) 型に逆シリアル化しようとします。
`string`	文字列としてのイベント。
BinaryData¹	イベントメッセージのバイト数。
CloudEvent¹	イベントオブジェクト。 CloudEvents スキーマを使用して配信するように Event Grid が構成されているときに使用します。
EventGridEvent¹	イベントオブジェクト。 Event Grid スキーマを使用して配信するように Event Grid が構成されているときに使用します。

関数でイベントのバッチを処理するとき、Event Grid トリガーは次の種類にバインドできます。

Type	説明
`CloudEvent[]`¹、 `EventGridEvent[]`¹、 `string[]`= `BinaryData[]`¹	バッチのイベントの配列。各エントリは 1 つのイベントを表します。

¹ これらの型を使用するには、Microsoft.Azure.Functions.Worker.Extensions.EventGrid 3.3.0 以降と SDK 型バインドの一般的な依存関係に関する記事を参照する必要があります。

Event Grid インスタンスは、EventGridTrigger 属性に関連付けられたパラメーターを介して、EventSchema と型指定して使用できます。

Event Grid インスタンスは、function.json ファイルの name プロパティで構成されたパラメーターを介して使用できます。

Event Grid インスタンスは、function.json ファイルの name プロパティで構成されたパラメーターを介して、func.EventGridEvent と型指定して使用できます。

イベントスキーマ

Event Grid イベントのデータは、HTTP 要求の本文内の JSON オブジェクトとして受信されます。 JSON は次の例のようになります。

[{
  "topic": "/subscriptions/{subscriptionid}/resourceGroups/eg0122/providers/Microsoft.Storage/storageAccounts/egblobstore",
  "subject": "/blobServices/default/containers/{containername}/blobs/blobname.jpg",
  "eventType": "Microsoft.Storage.BlobCreated",
  "eventTime": "2018-01-23T17:02:19.6069787Z",
  "id": "{guid}",
  "data": {
    "api": "PutBlockList",
    "clientRequestId": "{guid}",
    "requestId": "{guid}",
    "eTag": "0x8D562831044DDD0",
    "contentType": "application/octet-stream",
    "contentLength": 2248,
    "blobType": "BlockBlob",
    "url": "https://egblobstore.blob.core.windows.net/{containername}/blobname.jpg",
    "sequencer": "000000000000272D000000000003D60F",
    "storageDiagnostics": {
      "batchId": "{guid}"
    }
  },
  "dataVersion": "",
  "metadataVersion": "1"
}]

示されている例は、1 要素の配列です。 Event Grid は常に配列を送信し、配列で複数のイベントを送信できます。ランタイムは、配列の各要素に対して 1 回、関数を呼び出します。

イベント JSON データの最上位レベルのプロパティはすべてのイベントの種類で同じですが、data プロパティの内容は各イベントの種類に固有です。この例では、BLOB ストレージイベントのものです。

共通プロパティとイベント固有プロパティについて詳しくは、Event Grid のドキュメントの「イベントのプロパティ」をご覧ください。

次のステップ

ご質問がある場合は、こちらからチームに問題をお送りください
Event Grid イベントをディスパッチする

次の方法で共有

Azure Functions の Azure Event Grid トリガー

例

Event Grid グリッドトリガー、文字列パラメーター

Event Grid グリッドトリガー、POJO パラメーター

属性

注釈

構成

構成

使用方法

イベントスキーマ

次のステップ

フィードバック

その他のリソース

次の方法で共有

Azure Functions の Azure Event Grid トリガー

例

Event Grid グリッド トリガー、文字列パラメーター

Event Grid グリッド トリガー、POJO パラメーター

属性

注釈

構成

構成

使用方法

イベント スキーマ

次のステップ

フィードバック

その他のリソース

Event Grid グリッドトリガー、文字列パラメーター

Event Grid グリッドトリガー、POJO パラメーター

イベントスキーマ