feat(instr-openai): support openai@5

packages/instrumentation-openai/.tav.yml

@@ -1,5 +1,11 @@
 openai:
-  versions:
-    include: '>=4.19.0 <5'
-    mode: max-5
-  commands: npm test
+  - versions:
+      include: '>=4.19.0 <6'
+      mode: max-5
+    commands: npm test
+  # It is a little bit hacky to get TAV to consider prereleases.
+  # Once there are non-prerelease 5.x releases we can drop this block.
+  - versions:
+      include: '>=5.0.0-alpha.0 <5.0.0-rc.99'
+      mode: max-2
+    commands: npm test

packages/instrumentation-openai/CHANGELOG.md

@@ -1,5 +1,10 @@
 # @elastic/opentelemetry-instrumentation-openai Changelog
 
+## Unreleased
+
+- Support instrumenting openai@5, including preleases. Currently only 5.0.0-alpha.0
+  has been released.
+
 ## v0.4.1
 
 - Include "LICENSE" file in the published package.

packages/instrumentation-openai/package.json

@@ -74,6 +74,7 @@
     "@opentelemetry/exporter-metrics-otlp-proto": "^0.56.0",
     "@opentelemetry/exporter-trace-otlp-proto": "^0.56.0",
     "@opentelemetry/instrumentation-http": "^0.56.0",
+    "@opentelemetry/instrumentation-undici": "^0.9.0",
     "@opentelemetry/sdk-logs": "^0.56.0",
     "@opentelemetry/sdk-metrics": "^1.29.0",
     "@opentelemetry/sdk-node": "^0.56.0",
@@ -85,7 +86,7 @@
     "@typescript-eslint/parser": "5.8.1",
     "dotenv": "^16.4.5",
     "nock": "^13.5.5",
-    "openai": "^4.57.0",
+    "openai": "^4.78.0",
     "tape": "^5.8.1",
     "test-all-versions": "^6.1.0",
     "typescript": "4.4.4"

packages/instrumentation-openai/src/instrumentation.ts

@@ -26,6 +26,7 @@ import {
   InstrumentationBase,
   InstrumentationNodeModuleDefinition,
 } from '@opentelemetry/instrumentation';
+import type { InstrumentationModuleDefinition } from '@opentelemetry/instrumentation';
 import { SeverityNumber } from '@opentelemetry/api-logs';
 
 import {
@@ -98,10 +99,10 @@ export class OpenAIInstrumentation extends InstrumentationBase<OpenAIInstrumenta
   }
 
   protected init() {
-    return [
+    const defn: InstrumentationModuleDefinition =
       new InstrumentationNodeModuleDefinition(
         'openai',
-        ['>=4.19.0 <5'],
+        ['>=4.19.0 <6'],
         (modExports, modVer) => {
           debug(
             'instrument openai@%s (isESM=%s), config=%o',
@@ -122,8 +123,10 @@ export class OpenAIInstrumentation extends InstrumentationBase<OpenAIInstrumenta
 
           return modExports;
         }
-      ),
-    ];
+      );
+    // Allow instrumentation to work on prereleases, e.g. 5.0.0-alpha.0.
+    defn.includePrerelease = true;
+    return [defn];
   }
 
   // This is a 'protected' method on class `InstrumentationAbstract`.

packages/instrumentation-openai/test/fixtures.test.js

@@ -226,6 +226,7 @@ test('fixtures', async suite => {
   /** @type {import('./testutils').TestFixture[]} */
   let testFixtures = [
     {
+      only: true, // XXX HERE
       name: 'chat-completion (captureMessageContent=true)',
       args: ['./fixtures/chat-completion.js'],
       cwd: __dirname,
@@ -271,14 +272,17 @@ test('fixtures', async suite => {
         );
 
         if (!usingNock) {
-          t.equal(spans[1].scope.name, '@opentelemetry/instrumentation-http');
+          t.equal(spans[1].name, 'POST');
           t.equal(
             spans[1].parentSpanId,
             spans[0].spanId,
             'HTTP span is a child of the GenAI span'
           );
+          const urlPath =
+            spans[1].attributes['http.target'] || // older semconv
+            spans[1].attributes['url.path'];
           t.ok(
-            spans[1].attributes['http.target'].includes('/chat/completions'),
+            urlPath.includes('/chat/completions'),
             'looks like a .../chat/completions HTTP endpoint'
           );
         }
@@ -478,14 +482,17 @@ test('fixtures', async suite => {
         );
 
         if (!usingNock) {
-          t.equal(spans[1].scope.name, '@opentelemetry/instrumentation-http');
+          t.equal(spans[1].name, 'POST');
           t.equal(
             spans[1].parentSpanId,
             spans[0].spanId,
             'HTTP span is a child of the GenAI span'
           );
+          const urlPath =
+            spans[1].attributes['http.target'] || // older semconv
+            spans[1].attributes['url.path'];
           t.ok(
-            spans[1].attributes['http.target'].includes('/chat/completions'),
+            urlPath.includes('/chat/completions'),
             'looks like a .../chat/completions HTTP endpoint'
           );
         }
@@ -1244,14 +1251,17 @@ test('fixtures', async suite => {
         );
 
         if (!usingNock) {
-          t.equal(spans[1].scope.name, '@opentelemetry/instrumentation-http');
+          t.equal(spans[1].name, 'POST');
           t.equal(
             spans[1].parentSpanId,
             spans[0].spanId,
             'HTTP span is a child of the GenAI span'
           );
+          const urlPath =
+            spans[1].attributes['http.target'] || // older semconv
+            spans[1].attributes['url.path'];
           t.ok(
-            spans[1].attributes['http.target'].includes('/embeddings'),
+            urlPath.includes('/embeddings'),
             'looks like a .../embeddings HTTP endpoint'
           );
         }

packages/instrumentation-openai/test/fixtures/telemetry.js

@@ -30,6 +30,9 @@ const {
 const { OTLPLogExporter } = require('@opentelemetry/exporter-logs-otlp-proto');
 const { BatchLogRecordProcessor } = require('@opentelemetry/sdk-logs');
 const { HttpInstrumentation } = require('@opentelemetry/instrumentation-http');
+const {
+  UndiciInstrumentation,
+} = require('@opentelemetry/instrumentation-undici');
 const { OpenAIInstrumentation } = require('../../'); // @elastic/opentelemetry-instrumentation-openai
 const { PeriodicExportingMetricReader } = require('@opentelemetry/sdk-metrics');
 
@@ -50,7 +53,11 @@ const sdk = new NodeSDK({
   traceExporter: new OTLPTraceExporter(),
   logRecordProcessor,
   metricReader,
-  instrumentations: [new HttpInstrumentation(), new OpenAIInstrumentation()],
+  instrumentations: [
+    new HttpInstrumentation(),
+    new UndiciInstrumentation(), // openai@5 uses Node.js native fetch(), which is instrumented by instr-undici
+    new OpenAIInstrumentation(),
+  ],
 });
 
 process.on('SIGTERM', async () => {