Azure Functions의 Azure Event Grid 트리거

Python v2 프로그래밍 모델을 사용하면 Python 함수 코드에서 직접 데코레이터를 사용하여 바인딩을 정의할 수 있습니다. 자세한 내용은 Python 개발자 가이드를 참조하세요.

Python v1 프로그래밍 모델을 사용하려면 함수 폴더의 별도 function.json 파일에서 바인딩을 정의해야 합니다. 자세한 내용은 Python 개발자 가이드를 참조하세요.

격리된 작업자 프로세스에서 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
{

다음 예제에서는 바인딩 매개 변수를 사용하는 Functions 버전 4.x 함수를 CloudEvent 보여 줍니다.

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);
        }
    }
}

다음 예제에서는 바인딩 매개 변수를 사용하는 Functions 버전 4.x 함수를 EventGridEvent 보여 줍니다.

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));
        }
    }
}

다음 예에서는 이벤트 그리드 트리거 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,
});

TypeScript 샘플은 모델 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));
};

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)

다음은 메서드 서명의 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)
{

app.eventGrid() 메서드에 전달된 options 개체는 현재 모델 v4에 대한 속성을 지원하지 않습니다.

다음 표에서는 function.json 파일에 설정된 바인딩 구성 속성을 설명합니다.

In Process C# 클래스 라이브러리 함수는 다음 형식을 지원합니다.

• Azure.Messaging.CloudEvent
• Azure.Messaging.EventGrid
• Newtonsoft.Json.Linq.JObject
• System.String

In Process C# 클래스 라이브러리 함수는 다음 형식을 지원합니다.

• Microsoft.Azure.EventGrid.Models.EventGridEvent
• Newtonsoft.Json.Linq.JObject
• System.String

In Process C# 클래스 라이브러리 함수는 다음 형식을 지원합니다.

• Newtonsoft.Json.Linq.JObject
• System.String

함수가 단일 이벤트를 처리하도록 하려는 경우 Event Grid 트리거는 다음 형식에 바인딩될 수 있습니다.

함수가 이벤트 일괄 처리를 수행하려는 경우 Event Grid 트리거는 다음 형식에 바인딩될 수 있습니다.

¹ 이러한 형식을 사용하려면 Microsoft.Azure.Functions.Worker.Extensions.EventGrid 3.3.0 이상 및 SDK 형식 바인딩에 대한 공통 종속성을 참조해야 합니다.

사용자 지정 형식을 정의하거나 문자열을 사용해야 합니다. 사용자 지정 매개 변수 형식을 사용하는 예제는 예제 섹션을 참조하세요.

Functions 버전 1.x는 격리된 작업자 프로세스를 지원하지 않습니다.