Add open telemetry samples (#20)

Author: ejizba

js/package-lock.json

@@ -9,7 +9,11 @@
         "test": "echo \"No tests yet...\""
     },
     "dependencies": {
-        "@azure/functions": "^4.1.0"
+        "@azure/functions": "^4.5.0",
+        "@azure/monitor-opentelemetry-exporter": "^1.0.0-beta.23",
+        "@opentelemetry/api": "^1.8.0",
+        "@opentelemetry/auto-instrumentations-node": "^0.46.1",
+        "@opentelemetry/exporter-logs-otlp-http": "^0.51.1"
     },
     "devDependencies": {
         "eslint": "^7.32.0",

js/package.json

@@ -0,0 +1,62 @@
+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;
+    }
+}

js/src/otelAppInsights.js

@@ -0,0 +1,63 @@
+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;
+    }
+}