Azure Functions のカスタムハンドラー

[アーティクル]
06/01/2023

すべてのFunction App は、言語固有のハンドラーによって実行されます。 Azure Functions では多くの言語ハンドラーが既定でサポートされていますが、他の言語やランタイムを使用したい場合もあります。

カスタムハンドラーは、Functions ホストからイベントを受信する軽量の Web サーバーです。 HTTP プリミティブをサポートするすべての言語で、カスタムハンドラーを実装できます。

カスタムハンドラーは、次のような場合に最適です。

Go や Rust など、現在追加設定なしで提供されていない言語で関数アプリを実装します。
Deno など、現在既定でrサポートされていないランタイムで関数アプリを実装する。

カスタムハンドラーを使用すると、拡張バンドルを介して、トリガーと入出力バインドを使用できます。

Go および Rust のクイックスタートを使用して Azure Functions カスタムハンドラーの使用を開始します。

概要

次の図は、カスタムハンドラーとして実装されている Web サーバーと Functions ホストの関係を示しています。

Azure Functions のカスタムハンドラーの概要

各イベントは、Functions ホストに送信される要求をトリガーします。イベントは、Azure Functions によってサポートされている任意のトリガーです。
Functions ホストは、その後、Web サーバーに要求ペイロードを発行します。このペイロードには、トリガーおよび入力バインドデータと、関数のためのその他のメタデータが保持されます。
Web サーバーは個々の関数を実行し、応答ペイロードを Functions ホストに返します。
Functions ホストは、応答のデータを処理するために関数の出力バインドに渡します。

カスタムハンドラーとして実装されている Azure Functions アプリでは、いくつかの規則に従って、host.json、local.settings.json、および function.json ファイルを構成する必要があります。

アプリケーション構造

カスタムハンドラーを実装するには、アプリケーションに次の要素が必要です。

host.json ファイル: アプリのルート
local.settings.json ファイル: アプリのルート
function.json ファイル: 関数ごとに必要 (関数名と一致する名前のフォルダー内)
コマンド、スクリプト、または実行可能ファイル: Web サーバーを実行

次の図は、"MyQueueFunction" という名前の関数と、handler.exe という名前のカスタムハンドラー実行可能ファイルのファイルシステムでこれらのファイルがどのように表示されるかを示します。

| /MyQueueFunction
|   function.json
|
| host.json
| local.settings.json
| handler.exe

構成

アプリケーションは、host.json および local.settings.json ファイルを使用して構成されます。

host.json

host.json は、HTTP イベントを処理できる Web サーバーを指すことによって、要求の送信先を Functions ホストに指示します。

host.json ファイルの customHandler セクションで Web サーバーを実行する方法の詳細を構成することにより、カスタムハンドラーを定義します。

{
  "version": "2.0",
  "customHandler": {
    "description": {
      "defaultExecutablePath": "handler.exe"
    }
  }
}

customHandler セクションは、defaultExecutablePath で定義されているターゲットを指します。実行ターゲットは、Web サーバーが実装されているコマンド、実行可能ファイル、またはファイルにすることができます。

arguments 配列を使用して、引数を実行可能ファイルに渡します。引数では、%% 表記を使用した環境変数 (アプリケーション設定) の展開がサポートされています。

また、workingDirectory を使用して、実行可能ファイルによって使用される作業ディレクトリを変更することもできます。

{
  "version": "2.0",
  "customHandler": {
    "description": {
      "defaultExecutablePath": "app/handler.exe",
      "arguments": [
        "--database-connection-string",
        "%DATABASE_CONNECTION_STRING%"
      ],
      "workingDirectory": "app"
    }
  }
}

バインドのサポート

標準トリガーと入出力バインドは、host.json ファイル内の拡張バンドルを参照することによって利用できます。

local.settings.json

local.settings.json では、Function App をローカルで実行する際に使用されるアプリケーション設定を定義します。シークレットが含まれる可能性があるため、local.settings.json はソース管理から除外する必要があります。 Azure では、代わりにアプリケーション設定を使用します。

カスタムハンドラーの場合、local.settings.json で FUNCTIONS_WORKER_RUNTIME を Custom に設定します。

{
  "IsEncrypted": false,
  "Values": {
    "FUNCTIONS_WORKER_RUNTIME": "Custom"
  }
}

関数のメタデータ

function.json の内容をカスタムハンドラーと共に使用する場合、その内容は他のコンテキストで関数を定義する場合と変わりありません。唯一の要件は、function.json ファイルは、関数名と一致する名前のフォルダーに格納しなければならないということです。

次の function.json では、キュートリガーとキュー出力バインドを含む関数を構成しています。 MyQueueFunction という名前のフォルダー内にあるため、MyQueueFunction という名前の関数が定義されます。

MyQueueFunction/function.json

{
  "bindings": [
    {
      "name": "myQueueItem",
      "type": "queueTrigger",
      "direction": "in",
      "queueName": "messages-incoming",
      "connection": "AzureWebJobsStorage"
    },
    {
      "name": "$return",
      "type": "queue",
      "direction": "out",
      "queueName": "messages-outgoing",
      "connection": "AzureWebJobsStorage"
    }
  ]
}

要求ペイロード

キューメッセージを受信すると、Functions ホストはカスタムハンドラーに、ペイロードが本文にある HTTP POST 要求を送信します。

次のコードは、要求ペイロードのサンプルを表します。ペイロードには、2 つのメンバー (Data と Metadata) を持つ JSON 構造体が含まれています。

Data メンバーには、function.json ファイルにバインド配列の形式で定義されている入力名およびトリガー名と一致するキーが含まれています。

Metadata メンバーには、イベントソースから生成されたメタデータが含まれています。

{
  "Data": {
    "myQueueItem": "{ message: \"Message sent\" }"
  },
  "Metadata": {
    "DequeueCount": 1,
    "ExpirationTime": "2019-10-16T17:58:31+00:00",
    "Id": "800ae4b3-bdd2-4c08-badd-f08e5a34b865",
    "InsertionTime": "2019-10-09T17:58:31+00:00",
    "NextVisibleTime": "2019-10-09T18:08:32+00:00",
    "PopReceipt": "AgAAAAMAAAAAAAAAAgtnj8x+1QE=",
    "sys": {
      "MethodName": "QueueTrigger",
      "UtcNow": "2019-10-09T17:58:32.2205399Z",
      "RandGuid": "24ad4c06-24ad-4e5b-8294-3da9714877e9"
    }
  }
}

応答ペイロード:

規則により、関数の応答はキーと値のペアの形式で設定されます。サポートされているキーは次のとおりです。

ペイロードのキー	データ型	解説
`Outputs`	object	function.json の `bindings` 配列によって定義される応答値を保持します。たとえば、関数が "myQueueOutput" という名前のキュー出力バインドを使用して構成されている場合、`Outputs` には、`myQueueOutput` という名前のキーが格納されます。これは、カスタムハンドラーによって、キューに送信されるメッセージに設定されます。
`Logs`	array	Functions の呼び出しログにメッセージが表示されます。 Azure で実行すると、メッセージは Application Insights に表示されます。
`ReturnValue`	string	function.json ファイルの `$return` として出力が構成されている場合に、応答を提供するために使用されます。

これは、応答ペイロードの例です。

{
  "Outputs": {
    "res": {
      "body": "Message enqueued"
    },
    "myQueueOutput": [
      "queue message 1",
      "queue message 2"
    ]
  },
  "Logs": [
    "Log message 1",
    "Log message 2"
  ],
  "ReturnValue": "{\"hello\":\"world\"}"
}

例

カスタムハンドラーは、HTTP イベントの受信をサポートする任意の言語で実装できます。以下の例では、Go プログラミング言語を使用してカスタムハンドラーを実装する方法を示しています。

関数とバインド

この例で実装されているシナリオは、商品の注文を表すペイロードを持つ POST を受け入れる order という名前の関数を特徴としています。関数に注文がポストされると、Queue Storage メッセージが作成され、HTTP 応答が返されます。

実装

order という名前のフォルダー内の function.json ファイルで、HTTP によってトリガーされる関数を構成します。

order/function.json

{
  "bindings": [
    {
      "type": "httpTrigger",
      "direction": "in",
      "name": "req",
      "methods": ["post"]
    },
    {
      "type": "http",
      "direction": "out",
      "name": "res"
    },
    {
      "type": "queue",
      "name": "message",
      "direction": "out",
      "queueName": "orders",
      "connection": "AzureWebJobsStorage"
    }
  ]
}

この関数は HTTP によってトリガーされる関数として定義され、HTTP 応答を返し、Queue Storage メッセージを出力します。

アプリのルートにある host.json ファイルは、handler.exe (Linux または macOS の場合は handler) という名前の実行可能ファイルを実行するように構成されています。

{
  "version": "2.0",
  "customHandler": {
    "description": {
      "defaultExecutablePath": "handler.exe"
    }
  },
  "extensionBundle": {
    "id": "Microsoft.Azure.Functions.ExtensionBundle",
    "version": "[1.*, 2.0.0)"
  }
}

これは、Functions ランタイムに送信される HTTP 要求です。

POST http://127.0.0.1:7071/api/order HTTP/1.1
Content-Type: application/json

{
  "id": 1005,
  "quantity": 2,
  "color": "black"
}

その後、Functions ランタイムは次の HTTP 要求をカスタムハンドラーに送信します。

POST http://127.0.0.1:<FUNCTIONS_CUSTOMHANDLER_PORT>/order HTTP/1.1
Content-Type: application/json

{
  "Data": {
    "req": {
      "Url": "http://localhost:7071/api/order",
      "Method": "POST",
      "Query": "{}",
      "Headers": {
        "Content-Type": [
          "application/json"
        ]
      },
      "Params": {},
      "Body": "{\"id\":1005,\"quantity\":2,\"color\":\"black\"}"
    }
  },
  "Metadata": {
  }
}

Note

簡潔にするために、ペイロードの一部は削除されています。

handler.exe はコンパイル済みの Go カスタムハンドラープログラムで、Web サーバーを実行し、Functions ホストからの関数呼び出し要求に応答します。

package main

import (
	"encoding/json"
	"fmt"
	"log"
	"net/http"
	"os"
)

type InvokeRequest struct {
	Data     map[string]json.RawMessage
	Metadata map[string]interface{}
}

type InvokeResponse struct {
	Outputs     map[string]interface{}
	Logs        []string
	ReturnValue interface{}
}

func orderHandler(w http.ResponseWriter, r *http.Request) {
	var invokeRequest InvokeRequest

	d := json.NewDecoder(r.Body)
	d.Decode(&invokeRequest)

	var reqData map[string]interface{}
	json.Unmarshal(invokeRequest.Data["req"], &reqData)

	outputs := make(map[string]interface{})
	outputs["message"] = reqData["Body"]

	resData := make(map[string]interface{})
	resData["body"] = "Order enqueued"
	outputs["res"] = resData
	invokeResponse := InvokeResponse{outputs, nil, nil}

	responseJson, _ := json.Marshal(invokeResponse)

	w.Header().Set("Content-Type", "application/json")
	w.Write(responseJson)
}

func main() {
	customHandlerPort, exists := os.LookupEnv("FUNCTIONS_CUSTOMHANDLER_PORT")
	if !exists {
		customHandlerPort = "8080"
	}
	mux := http.NewServeMux()
	mux.HandleFunc("/order", orderHandler)
	fmt.Println("Go server Listening on: ", customHandlerPort)
	log.Fatal(http.ListenAndServe(":"+customHandlerPort, mux))
}

この例では、カスタムハンドラーは、HTTP イベントを処理するために Web サーバーを実行し、FUNCTIONS_CUSTOMHANDLER_PORT を介して要求をリッスンするように設定されています。

Functions ホストが /api/order で元の HTTP 要求を受信した場合でも、関数名 (そのフォルダー名) を使用してカスタムハンドラーを呼び出します。この例では、この関数が /order のパスで定義されています。ホストは、/order のパスで HTTP 要求をカスタムハンドラーに送信します。

POST 要求がこの関数に送信されると、トリガーのデータと関数のメタデータは、HTTP 要求本文を介して使用できるようになります。元の HTTP 要求本文には、ペイロードの Data.req.Body でアクセスできます。

関数の応答は、キーと値のペアの形式で設定されます。この場合、Outputs メンバーは、function.json ファイルで定義されている出力とキーが一致する JSON 値を保持します。

これは、このハンドラーが Functions ホストに返すペイロードの例です。

{
  "Outputs": {
    "message": "{\"id\":1005,\"quantity\":2,\"color\":\"black\"}",
    "res": {
      "body": "Order enqueued"
    }
  },
  "Logs": null,
  "ReturnValue": null
}

message 出力を、要求から送信された注文データと同じになるよう設定することで、この関数は、構成されたキューにその注文データを出力します。また、Functions ホストは、res で構成された HTTP 応答を呼び出し元に返します。

HTTP のみの関数

追加のバインドや出力がない HTTP トリガー関数の場合、カスタムハンドラーの要求および応答ペイロードではなく HTTP 要求と応答をハンドラーで直接操作したい場合があります。この動作は、host.json で enableForwardingHttpRequest 設定を使用して構成できます。

重要

カスタムハンドラー機能の主な目的は、現在 Azure Functions で最高レベルのサポートを受けていない言語とランタイムを有効にすることです。カスタムハンドラーを使用して Web アプリケーションを実行することはできますが、Azure Functions は標準のリバースプロキシではありません。応答ストリーミング、HTTP/2、WebSocket など、一部の機能は使用できません。 HTTP 要求の一部のコンポーネント (特定のヘッダーやルートなど) が制限される場合があります。アプリケーションでコールドスタートが過剰に発生する場合もあります。

このような状況に対処するには、Web アプリを Azure App Service で実行することを検討してください。

次の例では、追加のバインドまたは出力を使用せずに、HTTP によってトリガーされる関数を構成する方法を示します。この例で実装されているシナリオは、GET または POST を受け入れる hello という名前の関数を特徴としています。

実装

hello という名前のフォルダー内の function.json ファイルで、HTTP によってトリガーされる関数を構成します。

hello/function.json

{
  "bindings": [
    {
      "type": "httpTrigger",
      "authLevel": "anonymous",
      "direction": "in",
      "name": "req",
      "methods": ["get", "post"]
    },
    {
      "type": "http",
      "direction": "out",
      "name": "res"
    }
  ]
}

この関数は GET と POST の両方の要求を受け入れるように構成され、結果の値は res という名前の引数を使用して渡されます。

アプリのルートにある host.json ファイルは、handler.exe を実行するように構成され、enableForwardingHttpRequest は true に設定されています。

{
  "version": "2.0",
  "customHandler": {
    "description": {
      "defaultExecutablePath": "handler.exe"
    },
    "enableForwardingHttpRequest": true
  }
}

enableForwardingHttpRequest が true に設定されている場合、HTTP 専用関数の動作は、次のように、既定のカスタムハンドラーの動作とは異なります。

HTTP 要求には、カスタムハンドラーの要求ペイロードが含まれていません。代わりに、Functions ホストは元の HTTP 要求のコピーを使用してハンドラーを呼び出します。
Functions ホストは、すべてのクエリ文字列パラメーターを含む元の要求と同じパスのハンドラーを呼び出します。
Functions ホストは、元の要求への応答として、ハンドラーの HTTP 応答のコピーを返します。

以下は、Functions ホストに対する POST 要求です。その後、Functions ホストは、同じパスにあるカスタムハンドラーに要求のコピーを送信します。

POST http://127.0.0.1:7071/api/hello HTTP/1.1
Content-Type: application/json

{
  "message": "Hello World!"
}

handler.go ファイルは、Web サーバーと HTTP 関数を実装します。

package main

import (
	"fmt"
	"io/ioutil"
	"log"
	"net/http"
	"os"
)

func helloHandler(w http.ResponseWriter, r *http.Request) {
	w.Header().Set("Content-Type", "application/json")
	if r.Method == "GET" {
		w.Write([]byte("hello world"))
	} else {
		body, _ := ioutil.ReadAll(r.Body)
		w.Write(body)
	}
}

func main() {
	customHandlerPort, exists := os.LookupEnv("FUNCTIONS_CUSTOMHANDLER_PORT")
	if !exists {
		customHandlerPort = "8080"
	}
	mux := http.NewServeMux()
	mux.HandleFunc("/api/hello", helloHandler)
	fmt.Println("Go server Listening on: ", customHandlerPort)
	log.Fatal(http.ListenAndServe(":"+customHandlerPort, mux))
}

この例では、カスタムハンドラーは、HTTP イベントを処理するために Web サーバーを作成し、FUNCTIONS_CUSTOMHANDLER_PORT を介して要求をリッスンするように設定されています。

GET 要求は文字列を返すことによって処理され、POST 要求は要求本文にアクセスできます。

ここでの order 関数のルートは、元の要求と同じ /api/hello です。

Note

FUNCTIONS_CUSTOMHANDLER_PORT は、関数の呼び出しに使用されるパブリックポートではありません。このポートは、カスタムハンドラーを呼び出すために Functions ホストによって使用されます。

デプロイ中

カスタムハンドラーは、すべての Azure Functions ホスティングオプションにデプロイできます。ハンドラーにオペレーティングシステムまたはプラットフォームの依存関係 (言語のランタイムなど) が必要な場合は、カスタムコンテナーを使用する必要がある場合があります。

カスタムハンドラー用に Azure でFunction App を作成する場合は、スタックとして .NET Core を選択することをお勧めします。

Azure Functions Core Tools を使用してカスタムハンドラーアプリをデプロイするには、次のコマンドを実行します。

func azure functionapp publish $functionAppName

Note

カスタムハンドラーを実行するために必要なすべてのファイルがフォルダー内にあり、デプロイに含まれていることを確認します。カスタムハンドラーがバイナリ実行可能ファイルであるか、プラットフォーム固有の依存関係がある場合は、これらのファイルがターゲットデプロイプラットフォームと一致していることを確認します。

制限

カスタムハンドラー Web サーバーは、60 秒以内に起動する必要があります。

サンプル

さまざまな言語で関数を実装する方法の例については、カスタムハンドラーサンプル GitHub リポジトリを参照してください。

トラブルシューティングとサポート

Trace logging

カスタムハンドラープロセスの起動に失敗した場合、または Functions ホストとの通信に問題がある場合は、Function App のログレベルを Trace に上げて、ホストからの診断メッセージをさらに表示できます。

Function App の既定のログレベルを変更するには、host.json の logging セクションで logLevel 設定を構成します。

{
  "version": "2.0",
  "customHandler": {
    "description": {
      "defaultExecutablePath": "handler.exe"
    }
  },
  "logging": {
    "logLevel": {
      "default": "Trace"
    }
  }
}

Functions ホストは、カスタムハンドラープロセスに関連する情報を含む、追加のログメッセージを出力します。ログを使用して、カスタムハンドラープロセスを開始するときの問題、またはカスタムハンドラーで関数を呼び出すときの問題を調査します。

ローカルでは、ログはコンソールに出力されます。

Azure では、ログメッセージを表示するには Application Insights トレースのクエリを実行します。アプリによって大量のログが生成される場合は、ログメッセージのサブセットのみが Application Insights に送信されます。すべてのメッセージがログに記録されるようにするには、サンプリングを無効にします。

カスタムハンドラーを分離してテストする

カスタムハンドラーアプリは Web サーバープロセスであるため、モック HTTP 要求を送信することによって、独自に起動して関数呼び出しをテストすると便利な場合があります。ペイロードを使用して HTTP 要求を送信する場合は、データを安全に保つツールを選択するようにしてください。詳細については、「HTTP テストツール」を参照してください。

また、この方法を CI/CD パイプラインで使用して、カスタムハンドラーに対する自動テストを実行することもできます。

実行環境

カスタムハンドラーは、一般的な Azure Functions アプリと同じ環境で実行されます。ハンドラーをテストして、実行に必要なすべての依存関係が環境に含まれていることを確認します。追加の依存関係を必要とするアプリの場合は、Azure Functions の Premium プランでホストされているカスタムコンテナーイメージを使用して実行する必要がある場合があります。

サポートを受ける

カスタムハンドラーがあるFunction App に関するヘルプが必要な場合は、通常のサポートチャネルを通じてリクエストを送信できます。ただし、カスタムハンドラーアプリのビルドにはさまざまな言語が使用されるため、サポートは無制限ではありません。

Functions ホストの起動またはカスタムハンドラープロセスとの通信に問題がある場合は、サポートを利用できます。選択した言語またはフレームワークに関する問題など、カスタムハンドラープロセスの内部動作に固有の問題については、このコンテキストでサポートチームが支援を行うことができません。

次のステップ

カスタムハンドラーのクイックスタートを使用して、Go または Rust での Azure Functions アプリの構築を開始します。

次の方法で共有

Azure Functions のカスタムハンドラー

概要

アプリケーション構造

構成

host.json

バインドのサポート

local.settings.json

関数のメタデータ

要求ペイロード

応答ペイロード:

例

関数とバインド

実装

HTTP のみの関数

実装

デプロイ中

制限

サンプル

トラブルシューティングとサポート

Trace logging

カスタムハンドラーを分離してテストする

実行環境

サポートを受ける

次のステップ

フィードバック

その他のリソース

次の方法で共有

Azure Functions のカスタム ハンドラー

概要

アプリケーション構造

構成

host.json

バインドのサポート

local.settings.json

関数のメタデータ

要求ペイロード

応答ペイロード:

例

関数とバインド

実装

HTTP のみの関数

実装

デプロイ中

制限

サンプル

トラブルシューティングとサポート

Trace logging

カスタム ハンドラーを分離してテストする

実行環境

サポートを受ける

次のステップ

フィードバック

その他のリソース

Azure Functions のカスタムハンドラー

カスタムハンドラーを分離してテストする