Map http attributes to the stackdriver format (#652)

* Map http attributes to the stackdriver format

* update CHANGELOG

Author: mayurkale22

CHANGELOG.md

@@ -4,6 +4,7 @@ All notable changes to this project will be documented in this file.
 
 ## Unreleased
 - Fix a TypeError of url.parse (#640)
+- Map http attributes to the stackdriver format
 
 ## 0.0.17 - 2019-09-03
 - fix: allow override global trace params limits (#643)

packages/opencensus-exporter-stackdriver/src/stackdriver-cloudtrace-utils.ts

@@ -21,6 +21,16 @@ const AGENT_LABEL_KEY = 'g.co/agent';
 const AGENT_LABEL_VALUE_STRING = `opencensus-node [${coreTypes.version}]`;
 const AGENT_LABEL_VALUE = createAttributeValue(AGENT_LABEL_VALUE_STRING);
 
+const HTTP_ATTRIBUTE_MAPPING: { [key: string]: string } = {
+  'http.host': '/http/host',
+  'http.method': '/http/method',
+  'http.path': '/http/path',
+  'http.route': '/http/route',
+  'http.user_agent': '/http/user_agent',
+  'http.status_code': '/http/status_code',
+  'http.url': '/http/url',
+};
+
 /**
  * Creates StackDriver Links from OpenCensus Link.
  * @param links coreTypes.Link[]
@@ -132,7 +142,8 @@ function createAttributesBuilder(
 ): types.Attributes {
   const attributeMap: Record<string, types.AttributeValue> = {};
   for (const key of Object.keys(attributes)) {
-    attributeMap[key] = createAttributeValue(attributes[key]);
+    const mapKey = HTTP_ATTRIBUTE_MAPPING[key] || key;
+    attributeMap[mapKey] = createAttributeValue(attributes[key]);
   }
   return { attributeMap, droppedAttributesCount };
 }

packages/opencensus-exporter-stackdriver/test/test-stackdriver-cloudtrace-utils.ts

@@ -249,6 +249,39 @@ describe('Stackdriver CloudTrace Exporter Utils', () => {
         expectedAttributeMap
       );
     });
+
+    it('should map http attributes to the stackdriver format', () => {
+      const attributes = {
+        'http.host': 'localhost',
+        'http.method': 'GET',
+        'http.path': '/status',
+        'http.route': 'route',
+        'http.user_agent': 'agent',
+        'http.status_code': 200,
+        'http.url': 'http://localhost',
+      };
+
+      const expectedMap = {
+        'g.co/agent': {
+          stringValue: { value: `opencensus-node [${coreTypes.version}]` },
+        },
+        '/http/host': { stringValue: { value: 'localhost' } },
+        '/http/method': { stringValue: { value: 'GET' } },
+        '/http/path': { stringValue: { value: '/status' } },
+        '/http/route': { stringValue: { value: 'route' } },
+        '/http/user_agent': { stringValue: { value: 'agent' } },
+        '/http/status_code': { intValue: '200' },
+        '/http/url': { stringValue: { value: 'http://localhost' } },
+      };
+
+      const stackdriverAttribute = createAttributes(attributes, {}, 0);
+      assert.strictEqual(stackdriverAttribute.droppedAttributesCount, 0);
+      assert.strictEqual(
+        Object.keys(stackdriverAttribute.attributeMap!).length,
+        8
+      );
+      assert.deepStrictEqual(stackdriverAttribute.attributeMap, expectedMap);
+    });
   });
 
   describe('getResourceLabels()', () => {