fix: use parseLogAttributes

Author: wrn14897

package.json

@@ -18,7 +18,13 @@
     "prepare": "husky install"
   },
   "lint-staged": {
-    "**/*": "prettier --write --ignore-unknown"
+    "**/*.{ts,tsx}": [
+      "prettier --write --ignore-unknown",
+      "eslint --fix"
+    ],
+    "**/*.{json,yml}": [
+      "prettier --write --ignore-unknown"
+    ]
   },
   "devDependencies": {
     "@changesets/cli": "^2.26.1",

packages/node-opentelemetry/src/otel-logger/index.ts

@@ -21,6 +21,7 @@ import {
   NoopLogRecordProcessor,
 } from '@opentelemetry/sdk-logs';
 import { SEMRESATTRS_SERVICE_NAME } from '@opentelemetry/semantic-conventions';
+import isPlainObject from 'lodash.isplainobject';
 
 import { version as PKG_VERSION } from '../../package.json';
 import {
@@ -31,6 +32,7 @@ import {
   DEFAULT_SEND_INTERVAL_MS,
   DEFAULT_SERVICE_NAME,
 } from '../constants';
+import { jsonToString } from '../utils';
 
 const LOG_PREFIX = `⚠️  [LOGGER]`;
 
@@ -85,6 +87,32 @@ export function getSeverityNumber(level: string): SeverityNumber | undefined {
   return npmLevels[level] ?? sysLoglevels[level] ?? cliLevels[level];
 }
 
+export const parseLogAttributes = (
+  meta: Record<string, any>,
+): LogAttributes => {
+  try {
+    const attributes: LogAttributes = {};
+    for (const key in meta) {
+      if (Object.prototype.hasOwnProperty.call(meta, key)) {
+        const value = meta[key];
+        // stringify array of objects
+        if (Array.isArray(value)) {
+          const firstItem = value[0];
+          if (isPlainObject(firstItem)) {
+            attributes[key] = jsonToString(value);
+          }
+        } else {
+          attributes[key] = value;
+        }
+      }
+    }
+    return attributes;
+  } catch (error) {
+    diag.error(`${LOG_PREFIX} Failed to parse log attributes. e = ${error}`);
+    return meta;
+  }
+};
+
 export class Logger {
   private readonly _url: string;
 
@@ -204,19 +232,13 @@ export class Logger {
     body: string,
     meta: Record<string, any> = {},
   ): void {
-    const attributes: LogAttributes = {};
-    for (const key in meta) {
-      if (Object.prototype.hasOwnProperty.call(meta, key)) {
-        attributes[key] = meta[key];
-      }
-    }
     this.logger.emit({
       // TODO: should map to otel severity number
       severityNumber: getSeverityNumber(level),
       // TODO: set up the mapping between different downstream log levels
       severityText: level,
       body,
-      attributes,
+      attributes: parseLogAttributes(meta),
       timestamp: this.parseTimestamp(meta),
     });
   }