Page History

...

Library	Comment	Web Service	Supported versions
Express	Node.js application framework		4.x
Mongoose	MongoDB access		5.x
Sequelize	Node.js application framework		5.x; 6.x
TypeORM	ORM		0.2.x
Fastify	Node.js server		3.x
Axios	Promise based HTTP client		0.x
Node-mongodb-native	MongoDB access		3.x
nestjs	Node.js application framework		6.x; 7.x
https	Node.js web service
fetch	JavaScript builtin web service
request	HTTP request client 'request'		2.x
request-promise	HTTP request client 'request'		4.x
request-promise-native	HTTP request client 'request'		1.x
request-promise-any	HTTP request client 'request'		1.x
Mongo-client	MongoDB access
Couchdb	Couchdb access
Node-couchdb	Couchdb access
Couchdb-nano	Couchdb access
Marklogic	Marklogic access
my_connection	MySQL access		0.x
pg	PostgreSQL access		7.x; 8.x
oracledb	Oracle Database access		4.x; 5.x
node-sqlserver	MsnodeSQL access		0.x
mssql	MsSQL access		5.x; 6.x
Hapi	Node.js application framework
Sails	Node.js application framework
Loopback	Node.js application framework
Koa	Node.js application framework
Knex	Node.js SQL query builder
Memcached	Storage framework
AWS.DynamoDB	Amazon database access	SDK 2.x	AWS.S3	Amazon storage service	SDK 2.x
AWS.Lambda	Amazon routing solution		Cloudformation, Serverless framework, SAM
AWS.SQS	Amazon Simple Queue Service		SDK 2.x

...

Expand

Links

Link Type	Function
callLink	sendMessage sendMessageBatch receiveMessage

Support for SDK

This code will publish a message into the "SQS_QUEUE_URL" queue:

Code Block

language	js
linenumbers	true

import * as AWS from "aws-sdk";
AWS.config.update({ region: 'REGION' });

const sqs = new AWS.SQS({apiVersion: '2012-11-05'});

const queueUrl = "SQS_QUEUE_URL"

const params = {
	MessageBody: "This is a message",
    QueueUrl: queueUrl,
    MaxNumberOfMessages: 1,
    VisibilityTimeout: 0,
};


sqs.sendMessage(params, function (err, data) {
    if (err) {
        console.log("Error", err);
    } else {
        console.log("Success", data.MessageId);
    }
});
}

This code will receive a message from the queue "SQS_QUEUE_URL"

Code Block

language	js
linenumbers	true

import * as AWS from "aws-sdk";
AWS.config.update({ region: 'REGION' });

const sqs = new AWS.SQS({apiVersion: '2012-11-05'});

const queueUrl = "SQS_QUEUE_URL"

const params = {
    QueueUrl: queueUrl,
    MaxNumberOfMessages: 1,
    VisibilityTimeout: 0,
};

export class SqsReciver {
    constructor() {
        this.reciver();
    }
    private reciver(): void {
        sqs.receiveMessage(params, (err, data) => {
	// do something
        });
    }
}

What results can you expect?

Once the analysis/snapshot generation has been completed, you can view the results in the standard manner (for example via CAST Enlighten):

Click to enlarge

When the evaluation of the queue name fails, a Node.js AWS SQS Unknown Publisher (or Receiver) will be created.

Support for AWS Dynamodb

...

Support for AWS XRay

Expand

aws-xray encapsulates AWS methods calls in order to provide status and load status. However, the encapsulation did not allow the extension to provide objects and links. With the support of AWS XRay starting in 2.6.0-beta4, these objects and links will be created.

Code samples

This code will encapsulate AWS SDK then create a dynamoDB instance, and a Table instance.

Code Block

language	js

import AWSXRay from 'aws-xray-sdk-core'
import AWS from 'aws-sdk'
const AWS = AWSXRay.captureAWS(AWS) // Encapsulate AWS SDK
const DDB = new AWS.DynamoDB({ apiVersion: "2012-10-08" }) // use AWS as usual
const { v1: uuidv1 } = require('uuid');
 
// environment variables
const { TABLE_NAME, ENDPOINT_OVERRIDE, REGION } = process.env
const options = { region: REGION }
AWS.config.update({ region: REGION })
 
if (ENDPOINT_OVERRIDE !== "") {
    options.endpoint = ENDPOINT_OVERRIDE
}
 
const docClient = new AWS.DynamoDB.DocumentClient(options)
// response helper
const response = (statusCode, body, additionalHeaders) => ({
    statusCode,
    body: JSON.stringify(body),
    headers: { 'Content-Type': 'application/json', 'Access-Control-Allow-Origin': '*', ...additionalHeaders },
})
 

 
function addRecord(event) {
 
    let usernameField = {
        "cognito-username": getCognitoUsername(event)
    }
 
    // auto generated date fields
    let d = new Date()
    let dISO = d.toISOString()
    let auto_fields = {
        "id": uuidv1(),
        "creation_date": dISO,
        "lastupdate_date": dISO
    }
 
    //merge the json objects
    let item_body = {...usernameField, ...auto_fields, ...JSON.parse(event.body) }
 
    console.log(item_body);
     
    //final params to DynamoDB
    const params = {
        TableName: TABLE_NAME,
        Item: item_body
    }
 
    return docClient.put(params)
}

What results can you expect?

Once the analysis/snapshot generation has been completed, you can view the results with your favorite tool (for example via CAST Enlighten):

Click to enlarge

Analysis of the code sample

...

Page tree

Versions Compared

Old Version 11

New Version 12

Key

Links

Support for SDK

What results can you expect?

Support for AWS Dynamodb

Support for AWS XRay

Code samples