Azure Functions で OpenTelemetry を使用する

[アーティクル]
05/28/2024

重要

Azure Functions の OpenTelemetry サポートは現在プレビュー段階であり、OpenTelemetry を使用するには、Flex 従量課金プランでアプリをホストする必要があります。

この記事では、OpenTelemetry 形式でログおよびトレースデータをエクスポートするように関数アプリを構成する方法について説明します。 Azure Functions は、Functions ホストプロセスと、関数コードを実行する言語固有のワーカープロセスの両方から、関数の実行に関するテレメトリデータを生成します。既定では、このテレメトリデータは Application Insights SDK を使用して Application Insights に送信されます。ただし、OpenTelemetry セマンティクスを使用してこのデータをエクスポートすることもできます。 OpenTelemetry 形式を使用して Application Insights にデータを送信することはできますが、同じデータを他の OpenTelemetry 準拠のエンドポイントにエクスポートすることもできます。

ヒント

この記事は選択された開発言語を対象としているため、記事の上部で適切な言語を必ず選択してください。

現時点では、Java アプリに対するクライアント最適化 OpenTelemetry のサポートはありません。

OpenTelemetry は現在、C# インプロセスアプリではサポートされていません。

関数アプリで OpenTelemetry を有効にすると、次の利点が得られます。

ホストとアプリケーションコードの両方で生成されるトレースとログ間の相関関係。
エクスポート可能なテレメトリデータの一貫性のある標準ベースの生成。
OpenTeleletry 準拠のデータを使用できる他のプロバイダーとの統合。

OpenTelemetry は、ホスト構成 (host.json) とコードプロジェクトの両方で、関数アプリレベルで有効になります。関数は、言語固有のワーカープロセスで実行されている関数コードから OpenTelemetry データをエクスポートするためのクライアント最適化エクスペリエンスも提供します。

1.Functions ホストで OpenTelemetry を有効にする

関数アプリの host.json ファイルで OpenTelemetry 出力を有効にすると、アプリで使用されている言語スタックに関わらず、ホストによって OpenTelemetry 出力がエクスポートされます。

Functions ホストからの OpenTelemetry 出力を有効にするには、コードプロジェクトの host.json ファイルを更新して、ルートコレクションに "telemetryMode": "openTelemetry" 要素を追加します。 OpenTelemetry を有効にすると、host.json ファイルは次のようになります。

{
    "version": "2.0",
    "logging": {
        "applicationInsights": {
            "samplingSettings": {
                "isEnabled": true,
                "excludedTypes": "Request"
            },
            "enableLiveMetricsFilters": true
        }
    },
    "telemetryMode": "openTelemetry"
}

2.アプリケーション設定の構成

host.json ファイルで OpenTelemetry が有効になっている場合、データの送信先のエンドポイントは、アプリの環境変数で使用できる OpenTelemetry でサポートされるアプリケーション設定に基づいて決定されます。

OpenTelemetry の出力先に基づいて、関数アプリで特定のアプリケーション設定を作成します。 Application Insights と OpenTelemetry プロトコル (OTLP) エクスポーターの両方に接続設定が指定されている場合、OpenTelemetry データは両方のエンドポイントに送信されます。

Application Insights
OTLP エクスポーター

APPLICATIONINSIGHTS_CONNECTION_STRING: Application Insights ワークスペースの接続文字列。この設定が存在すると、OpenTelemetry データがそのワークスペースに送信されます。この設定は、OpenTelemetry を有効にせずに Application Insights に接続するために使用される設定と同じです。アプリにこの設定がまだない場合は、Application Insights の統合を有効にする必要がある場合があります。

OTEL_EXPORTER_OTLP_ENDPOINT: OTLP エクスポーターエンドポイントの URL。

OTEL_EXPORTER_OTLP_HEADERS: (省略可能) すべての送信データに適用するヘッダーの一覧。これは、API キーを渡すために多くのエンドポイントで使用されます。

エンドポイントで他の環境変数を設定する必要がある場合は、それらをアプリケーション設定にも追加する必要があります。詳細については、OTLP エクスポーター構成のドキュメントをご覧ください。

ホストから Application Insights に送信された OpenTelemetry 出力も必要な場合を除き、APPLICATIONINSIGHTS_CONNECTION_STRING 設定を削除する必要があります。

3.アプリで OpenTelemetry を有効にする

OpenTelemetry を使用するように Functions ホストが構成されている場合は、OpenTelemetry データを出力するようにアプリケーションコードを更新する必要もあります。ホストとアプリケーションコードの両方で OpenTelemetry を有効にすると、Functions ホストプロセスと言語ワーカープロセスの両方から出力されるトレースとログ間の相関関係が向上します。

OpenTelemetry を使用するようにアプリケーションをインストルメント化する方法は、ターゲットの OpenTelemetry エンドポイントによって異なります。

次のコマンドを実行して、必要なアセンブリをアプリにインストールします。

Application Insights
OTLP エクスポーター

dotnet add package Microsoft.Azure.Functions.Worker.OpenTelemetry --version 1.0.0-preview1 
dotnet add package OpenTelemetry.Extensions.Hosting 
dotnet add package Azure.Monitor.OpenTelemetry.AspNetCore

dotnet add package Microsoft.Azure.Functions.Worker.OpenTelemetry --version 1.0.0-preview1 
dotnet add package OpenTelemetry.Extensions.Hosting 
dotnet add package OpenTelemetry.Exporter.OpenTelemetryProtocol

Program.cs プロジェクトファイルに、次の using ステートメントを追加します。
- Application Insights
- OTLP エクスポーター
```
using Azure.Monitor.OpenTelemetry.AspNetCore; 
```
```
using OpenTelemetry; 
```
ConfigureServices デリゲートで、次のサービス構成を追加します。
- Application Insights
- OTLP エクスポーター
```
services.AddOpenTelemetry()
.UseFunctionsWorkerDefaults()
.UseAzureMonitor();
```
```
services.AddOpenTelemetry()
.UseFunctionsWorkerDefaults()
.UseOtlpExporter();
```
両方の OpenTelemetry エンドポイントにエクスポートするには、UseAzureMonitor と UseOtlpExporter の両方を呼び出します。

Java ワーカーの最適化は、OpenTelemetry ではまだ利用できないので、Java コードで設定することは何もありません。

プロジェクトディレクトリに次の npm パッケージをインストールします。

Application Insights
OTLP エクスポーター

npm install @opentelemetry/api 
npm install @opentelemetry/auto-instrumentations-node 
npm install @azure/monitor-opentelemetry-exporter

npm install @opentelemetry/api 
npm install @opentelemetry/auto-instrumentations-node 
npm install @opentelemetry/exporter-logs-otlp-http

プロジェクトにコードファイルを作成し、この新しいファイルに次のコードをコピーして貼り付け、ファイルを src/index.js として保存します。

Application Insights
OTLP エクスポーター

const { app } = require('@azure/functions');
const { AzureMonitorLogExporter, AzureMonitorTraceExporter } = require('@azure/monitor-opentelemetry-exporter');
const { context: otelContext, propagation } = require('@opentelemetry/api');
const { SeverityNumber } = require('@opentelemetry/api-logs');
const { getNodeAutoInstrumentations, getResourceDetectors } = require('@opentelemetry/auto-instrumentations-node');
const { registerInstrumentations } = require('@opentelemetry/instrumentation');
const { detectResourcesSync } = require('@opentelemetry/resources');
const { LoggerProvider, SimpleLogRecordProcessor } = require('@opentelemetry/sdk-logs');
const { NodeTracerProvider, SimpleSpanProcessor } = require('@opentelemetry/sdk-trace-node');

const resource = detectResourcesSync({ detectors: getResourceDetectors() });

const tracerProvider = new NodeTracerProvider({ resource });
tracerProvider.addSpanProcessor(new SimpleSpanProcessor(new AzureMonitorTraceExporter()));
tracerProvider.register();

const loggerProvider = new LoggerProvider({ resource });
loggerProvider.addLogRecordProcessor(new SimpleLogRecordProcessor(new AzureMonitorLogExporter()));

registerInstrumentations({ tracerProvider, loggerProvider, instrumentations: [getNodeAutoInstrumentations()] });

// NOTE: The below code will soon be a part of a new package `@opentelemetry/instrumentation-azure-functions`
// See here for more info: https://github.com/Azure/azure-functions-nodejs-library/issues/245
app.setup({ capabilities: { WorkerOpenTelemetryEnabled: true } });

const logger = loggerProvider.getLogger('default');
app.hook.log((context) => {
    logger.emit({
        body: context.message,
        severityNumber: toOtelSeverityNumber(context.level),
        severityText: context.level,
    });
});

app.hook.preInvocation((context) => {
    context.functionHandler = otelContext.bind(
        propagation.extract(otelContext.active(), {
            traceparent: context.invocationContext.traceContext.traceParent,
            tracestate: context.invocationContext.traceContext.traceState,
        }),
        context.functionHandler
    );
});

function toOtelSeverityNumber(level) {
    switch (level) {
        case 'information':
            return SeverityNumber.INFO;
        case 'debug':
            return SeverityNumber.DEBUG;
        case 'error':
            return SeverityNumber.ERROR;
        case 'trace':
            return SeverityNumber.TRACE;
        case 'warning':
            return SeverityNumber.WARN;
        case 'critical':
            return SeverityNumber.FATAL;
        default:
            return SeverityNumber.UNSPECIFIED;
    }
}

const { app } = require('@azure/functions');
const { context: otelContext, propagation } = require('@opentelemetry/api');
const { SeverityNumber } = require('@opentelemetry/api-logs');
const { getNodeAutoInstrumentations, getResourceDetectors } = require('@opentelemetry/auto-instrumentations-node');
const { OTLPLogExporter } = require('@opentelemetry/exporter-logs-otlp-http');
const { OTLPTraceExporter } = require('@opentelemetry/exporter-trace-otlp-http');
const { registerInstrumentations } = require('@opentelemetry/instrumentation');
const { detectResourcesSync } = require('@opentelemetry/resources');
const { LoggerProvider, SimpleLogRecordProcessor } = require('@opentelemetry/sdk-logs');
const { NodeTracerProvider, SimpleSpanProcessor } = require('@opentelemetry/sdk-trace-node');

const resource = detectResourcesSync({ detectors: getResourceDetectors() });

const tracerProvider = new NodeTracerProvider({ resource });
tracerProvider.addSpanProcessor(new SimpleSpanProcessor(new OTLPTraceExporter()));
tracerProvider.register();

const loggerProvider = new LoggerProvider({ resource });
loggerProvider.addLogRecordProcessor(new SimpleLogRecordProcessor(new OTLPLogExporter()));

registerInstrumentations({ tracerProvider, loggerProvider, instrumentations: [getNodeAutoInstrumentations()] });

// NOTE: The below code will soon be a part of a new package `@opentelemetry/instrumentation-azure-functions`
// See here for more info: https://github.com/Azure/azure-functions-nodejs-library/issues/245
app.setup({ capabilities: { WorkerOpenTelemetryEnabled: true } });

const logger = loggerProvider.getLogger('default');
app.hook.log((context) => {
    logger.emit({
        body: context.message,
        severityNumber: toOtelSeverityNumber(context.level),
        severityText: context.level,
    });
});

app.hook.preInvocation((context) => {
    context.functionHandler = otelContext.bind(
        propagation.extract(otelContext.active(), {
            traceparent: context.invocationContext.traceContext.traceParent,
            tracestate: context.invocationContext.traceContext.traceState,
        }),
        context.functionHandler
    );
});

function toOtelSeverityNumber(level) {
    switch (level) {
        case 'information':
            return SeverityNumber.INFO;
        case 'debug':
            return SeverityNumber.DEBUG;
        case 'error':
            return SeverityNumber.ERROR;
        case 'trace':
            return SeverityNumber.TRACE;
        case 'warning':
            return SeverityNumber.WARN;
        case 'critical':
            return SeverityNumber.FATAL;
        default:
            return SeverityNumber.UNSPECIFIED;
    }
}

package.json ファイルの main フィールドを更新して、この新しい src/index.js ファイルを含めます。これは次のようになります。
```
"main": "src/{index.js,functions/*.js}"
```

プロジェクトにコードファイルを作成し、この新しいファイルに次のコードをコピーして貼り付け、ファイルを src/index.ts として保存します。

Application Insights
OTLP エクスポーター

import { app, LogLevel } from '@azure/functions';
import { AzureMonitorLogExporter, AzureMonitorTraceExporter } from '@azure/monitor-opentelemetry-exporter';
import { context as otelContext, propagation } from '@opentelemetry/api';
import { SeverityNumber } from '@opentelemetry/api-logs';
import { getNodeAutoInstrumentations, getResourceDetectors } from '@opentelemetry/auto-instrumentations-node';
import { registerInstrumentations } from '@opentelemetry/instrumentation';
import { detectResourcesSync } from '@opentelemetry/resources';
import { LoggerProvider, SimpleLogRecordProcessor } from '@opentelemetry/sdk-logs';
import { NodeTracerProvider, SimpleSpanProcessor } from '@opentelemetry/sdk-trace-node';

const resource = detectResourcesSync({ detectors: getResourceDetectors() });

const tracerProvider = new NodeTracerProvider({ resource });
tracerProvider.addSpanProcessor(new SimpleSpanProcessor(new AzureMonitorTraceExporter()));
tracerProvider.register();

const loggerProvider = new LoggerProvider({ resource });
loggerProvider.addLogRecordProcessor(new SimpleLogRecordProcessor(new AzureMonitorLogExporter()));

registerInstrumentations({ tracerProvider, loggerProvider, instrumentations: [getNodeAutoInstrumentations()] });

// NOTE: The below code will soon be a part of a new package `@opentelemetry/instrumentation-azure-functions`
// See here for more info: https://github.com/Azure/azure-functions-nodejs-library/issues/245
app.setup({ capabilities: { WorkerOpenTelemetryEnabled: true } });

const logger = loggerProvider.getLogger('default');
app.hook.log((context) => {
    logger.emit({
        body: context.message,
        severityNumber: toOtelSeverityNumber(context.level),
        severityText: context.level,
    });
});

app.hook.preInvocation((context) => {
    context.functionHandler = otelContext.bind(
        propagation.extract(otelContext.active(), {
            traceparent: context.invocationContext.traceContext.traceParent,
            tracestate: context.invocationContext.traceContext.traceState,
        }),
        context.functionHandler
    );
});

function toOtelSeverityNumber(level: LogLevel): SeverityNumber {
    switch (level) {
        case 'information':
            return SeverityNumber.INFO;
        case 'debug':
            return SeverityNumber.DEBUG;
        case 'error':
            return SeverityNumber.ERROR;
        case 'trace':
            return SeverityNumber.TRACE;
        case 'warning':
            return SeverityNumber.WARN;
        case 'critical':
            return SeverityNumber.FATAL;
        default:
            return SeverityNumber.UNSPECIFIED;
    }
}

import { app, LogLevel } from '@azure/functions';
import { context as otelContext, propagation } from '@opentelemetry/api';
import { SeverityNumber } from '@opentelemetry/api-logs';
import { getNodeAutoInstrumentations, getResourceDetectors } from '@opentelemetry/auto-instrumentations-node';
import { OTLPLogExporter } from '@opentelemetry/exporter-logs-otlp-http';
import { OTLPTraceExporter } from '@opentelemetry/exporter-trace-otlp-http';
import { registerInstrumentations } from '@opentelemetry/instrumentation';
import { detectResourcesSync } from '@opentelemetry/resources';
import { LoggerProvider, SimpleLogRecordProcessor } from '@opentelemetry/sdk-logs';
import { NodeTracerProvider, SimpleSpanProcessor } from '@opentelemetry/sdk-trace-node';

const resource = detectResourcesSync({ detectors: getResourceDetectors() });

const tracerProvider = new NodeTracerProvider({ resource });
tracerProvider.addSpanProcessor(new SimpleSpanProcessor(new OTLPTraceExporter()));
tracerProvider.register();

const loggerProvider = new LoggerProvider({ resource });
loggerProvider.addLogRecordProcessor(new SimpleLogRecordProcessor(new OTLPLogExporter()));

registerInstrumentations({ tracerProvider, loggerProvider, instrumentations: [getNodeAutoInstrumentations()] });

// NOTE: The below code will soon be a part of a new package `@opentelemetry/instrumentation-azure-functions`
// See here for more info: https://github.com/Azure/azure-functions-nodejs-library/issues/245
app.setup({ capabilities: { WorkerOpenTelemetryEnabled: true } });

const logger = loggerProvider.getLogger('default');
app.hook.log((context) => {
    logger.emit({
        body: context.message,
        severityNumber: toOtelSeverityNumber(context.level),
        severityText: context.level,
    });
});

app.hook.preInvocation((context) => {
    context.functionHandler = otelContext.bind(
        propagation.extract(otelContext.active(), {
            traceparent: context.invocationContext.traceContext.traceParent,
            tracestate: context.invocationContext.traceContext.traceState,
        }),
        context.functionHandler
    );
});

function toOtelSeverityNumber(level: LogLevel): SeverityNumber {
    switch (level) {
        case 'information':
            return SeverityNumber.INFO;
        case 'debug':
            return SeverityNumber.DEBUG;
        case 'error':
            return SeverityNumber.ERROR;
        case 'trace':
            return SeverityNumber.TRACE;
        case 'warning':
            return SeverityNumber.WARN;
        case 'critical':
            return SeverityNumber.FATAL;
        default:
            return SeverityNumber.UNSPECIFIED;
    }
}

package.json ファイルの main フィールドを更新して、この新しい src/index.ts ファイルの出力を含めます。これは、次のようになります。
```
"main": "dist/src/{index.js,functions/*.js}"
```

重要

言語ワーカーからの Application Insights への OpenTelemetry 出力は、PowerShell アプリでは現在サポートされていません。代わりに、OTLP エクスポーターエンドポイントを使用することもできます。ホストが Application Insights への OpenTelemetry 出力用に構成されている場合、PowerShell ワーカープロセスによって生成されたログは引き続き転送されますが、現在、分散トレースはサポートされていません。

これらの手順は、OTLP エクスポーターにのみ適用されます。

値が True の OTEL_FUNCTIONS_WORKER_ENABLED という名前のアプリケーション設定を追加します。
アプリのルートにアプリレベルの Modules フォルダーを作成し、次のコマンドを実行します。
```
Save-Module -Name AzureFunctions.PowerShell.OpenTelemetry.SDK
```
これにより、必要な AzureFunctions.PowerShell.OpenTelemetry.SDK モジュールがアプリに直接インストールされます。 requirements.psd1 ファイルを使用してこの依存関係を自動的にインストールすることはできません。マネージド依存関係は、Flex 従量課金プランプレビューでは現在サポートされていないためです。

次のコードを profile.ps1 ファイルに追加します。

Import-Module AzureFunctions.PowerShell.OpenTelemetry.SDK -Force -ErrorAction Stop 
Initialize-FunctionsOpenTelemetry

requirements.txt ファイルに次のエントリを追加します。

Application Insights
OTLP エクスポーター

azure.monitor.opentelemetry

opentelemetry-api
opentelemetry-sdk
opentelemetry-exporter-otlp
opentelemetry-instrumentation-logging

function_app.py メインエントリポイントファイルに次のコードを追加します。

Application Insights
OTLP エクスポーター

from azure.monitor.opentelemetry import configure_azure_monitor 
configure_azure_monitor()

OpenTelemetry を使用してエクスポートされるトレース、メトリック、ログは、手動で構成する必要があります。詳細については、Python の「インストルメンテーション」をご覧ください。

これは、ログをエクスポートするための簡単な実装です。

logging.basicConfig(level=logging.DEBUG)

from opentelemetry import _logs
from opentelemetry.sdk._logs import LoggerProvider, LoggingHandler
from opentelemetry.sdk._logs.export import BatchLogRecordProcessor
from opentelemetry.exporter.otlp.proto.http._log_exporter import OTLPLogExporter

# Initialize logging and an exporter that can send data to an OTLP endpoint by attaching OTLP handler to root logger
# SELECT * FROM Log WHERE instrumentation.provider='opentelemetry'
_logs.set_logger_provider(
    LoggerProvider(resource=Resource.create(OTEL_RESOURCE_ATTRIBUTES))
)
logging.getLogger().addHandler(
    LoggingHandler(
        logger_provider=_logs.get_logger_provider().add_log_record_processor(
            BatchLogRecordProcessor(OTLPLogExporter())
        )
    )
)

OpenTelemetry コンポーネントを使用してログを収集する方法については、OpenTelemetry Logging SDK をご確認ください。

OpenTelemetry に関する考慮事項

OpenTelemetry を使用してデータをエクスポートする場合は、これらの現在の考慮事項に留意してください。

ホストが OpenTelemetry を使用するように構成されている場合、ログとトレースのみがエクスポートされます。ホストメトリックは、現在エクスポートされません。
現在、ホストで OpenTelemetry を有効にしている場合、Core Tools を使用してアプリプロジェクトをローカルで実行することはできません。現在、OpenTelemetry 関連の更新プログラムを検証するには、コードを Azure にデプロイする必要があります。
現時点では、OpenTelemetry 出力では HTTP トリガーと Azure SDK ベースのトリガーのみがサポートされています。

Azure Functions の監視 Flex 従量課金プラン

次の方法で共有

Azure Functions で OpenTelemetry を使用する

1.Functions ホストで OpenTelemetry を有効にする

2.アプリケーション設定の構成

3.アプリで OpenTelemetry を有効にする

OpenTelemetry に関する考慮事項

フィードバック

フィードバック

その他のリソース

次の方法で共有

Azure Functions で OpenTelemetry を使用する

1.Functions ホストで OpenTelemetry を有効にする

2.アプリケーション設定の構成

3.アプリで OpenTelemetry を有効にする

OpenTelemetry に関する考慮事項

関連するコンテンツ

フィードバック

フィードバック

その他のリソース