add logs processor

Author: liustve

aws-distro-opentelemetry-node-autoinstrumentation/src/aws-opentelemetry-configurator.ts

@@ -402,6 +402,7 @@ export class ApplicationSignalsExporterProvider {
 }
 
 export class AwsLoggerProcessorProvider {
+  
   private _logRecordProcessors: LogRecordProcessor[] = [];
 
   constructor() {
@@ -413,7 +414,7 @@ export class AwsLoggerProcessorProvider {
   }
 
   private configureLoggerProviderFromEnv(): void {
-    const otlpExporterLogsEndpoint = process.env['OTEL_EXPORTER_OTLP_TRACES_ENDPOINT'];
+    const otlpExporterLogsEndpoint = process.env['OTEL_EXPORTER_OTLP_LOGS_ENDPOINT'];
     const enabledExporters = AwsLoggerProcessorProvider.getStringListFromEnv('OTEL_LOGS_EXPORTER') ?? [];
 
     if (enabledExporters.length === 0) {

aws-distro-opentelemetry-node-autoinstrumentation/src/exporter/otlp/aws/common/aws-authenticator.ts

@@ -44,7 +44,7 @@ export class AwsAuthenticator {
 
       const cleanedHeaders = this.removeSigV4Headers(headers);
 
-      const request = new HttpRequest.httpRequest({
+      const request = new HttpRequest({
         method: 'POST',
         protocol: 'https',
         hostname: url.hostname,

aws-distro-opentelemetry-node-autoinstrumentation/src/exporter/otlp/aws/logs/otlp-aws-log-exporter.ts

@@ -25,7 +25,7 @@ export class OTLPAwsLogExporter extends OTLPProtoLogExporter {
     super(changeUrlConfig(endpoint, config));
     this.region = endpoint.split('.')[1];
     this.endpoint = endpoint;
-    this.authenticator = new AwsAuthenticator(this.region, 'xray');
+    this.authenticator = new AwsAuthenticator(this.region, 'logs');
   }
 
   /**
@@ -37,6 +37,7 @@ export class OTLPAwsLogExporter extends OTLPProtoLogExporter {
     items: ReadableLogRecord[],
     resultCallback: (result: ExportResult) => void
   ): Promise<void> {
+    
     const serializedLogs: Uint8Array | undefined = ProtobufLogsSerializer.serializeRequest(items);
     const headers = this['_delegate']._transport?._transport?._parameters?.headers();