AWS Stack Test

README.md

@@ -4,5 +4,8 @@
 
 You can find example usages for zipkin.js in different scenarios:
 
-- [web](web/)
+- [web](web/), In the web you can find the http-recorder, and the aws-sqs-recorder
 - [react-native](react-native-example/)
+
+## AWS Test
+In the aws folder, you have a docker-compose to get start with the zipkin-aws stack (SQS Collector, Kinesis Collector and AWS ES) and a localstack(mock AWS Services like SQS)

aws/docker-compose.yml

@@ -0,0 +1,25 @@
+version: "2.1"
+
+services:
+  localstack:
+    image: localstack/localstack
+    ports:
+      - '4566-4599:4566-4599'
+      - '8080:8080'
+    environment:
+      AWS_DEFAULT_REGION: us-east-1
+      AWS_ACCESS_KEY_ID: test
+      AWS_SECRET_ACCESS_KEY: test
+    volumes:
+      - './localstack-init.sh:/docker-entrypoint-initaws.d/init.sh'
+  zipkin-aws:
+    image: openzipkin/zipkin-aws
+    ports:
+      - '9411:9411'
+    environment:
+      SQS_QUEUE_URL: http://localstack:4576/queue/sqs-test
+      AWS_REGION: us-east-1
+      AWS_ACCESS_KEY_ID: test
+      AWS_SECRET_ACCESS_KEY: test
+    depends_on:
+      - localstack

aws/localstack-init.sh

@@ -0,0 +1,3 @@
+#!/bin/bash
+
+aws --endpoint-url=http://localhost:4576 sqs create-queue --queue-name sqs-test

web/aws-sqs-recorder.js

@@ -0,0 +1,24 @@
+/* eslint-env browser */
+const {
+    BatchRecorder
+} = require('zipkin');
+const {AwsSqsLogger} = require('zipkin-transport-aws-sqs');
+
+let awsSqsLogger = new AwsSqsLogger({
+    queueUrl: "http://localhost:4576/queue/sqs-test", //mandatory
+    region: 'us-east-1', // optional, region string
+    credentialProvider: {
+        accessKeyId: 'test',
+        secretAccessKey: 'test'
+    },
+    delaySeconds: 0// optional
+});
+
+
+function recorder(serviceName) {
+    return new BatchRecorder({
+        logger: awsSqsLogger
+    });
+}
+
+module.exports.recorder = recorder;

web/backend.js

@@ -4,6 +4,7 @@ const express = require('express');
 const CLSContext = require('zipkin-context-cls');
 const {Tracer} = require('zipkin');
 const {recorder} = require('./recorder');
+//const {recorder} = require('./aws-sqs-recorder');
 
 const ctxImpl = new CLSContext('zipkin');
 const localServiceName = 'backend';

web/package.json

@@ -17,12 +17,13 @@
     "express": "^4.0",
     "node-fetch": "^2.6.0",
     "npm": "^6.9",
-    "zipkin": "^0.19.1",
+    "zipkin": "^0.19.2",
     "zipkin-context-cls": "^0.19.0",
-    "zipkin-instrumentation-axiosjs": "^0.19.1",
-    "zipkin-instrumentation-express": "^0.19.1",
-    "zipkin-instrumentation-fetch": "^0.19.1",
-    "zipkin-transport-http": "^0.19.1"
+    "zipkin-instrumentation-axiosjs": "^0.19.2",
+    "zipkin-instrumentation-express": "^0.19.2",
+    "zipkin-instrumentation-fetch": "^0.19.2",
+    "zipkin-transport-http": "^0.19.2",
+    "zipkin-transport-aws-sqs": "^0.21.0"
   },
   "devDependencies": {
     "browserify": "^16.2",