How to use the SQS function from aws-sdk

queue.md?plain=1

GitHub: getlift/lift

74
75
76
77
78
79
80
81
82
Our `publisher` function can send messages into the SQS queue using the AWS SDK:

```js
// src/publisher.js
const AWS = require('aws-sdk');
const sqs = new AWS.SQS({
    apiVersion: 'latest',
    region: process.env.AWS_REGION,
});

92

835

19

+ 5 other calls in file

trace-sqs-receive-messages.js

GitHub: elastic/apm-agent-nodejs

49
50
51
52
53
54
55
56
57
58
  process.exit()
}
console.log('SQS ReceiveMessage from region=%s queueName=%s', region, queueName)

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

// For tracing spans to be created, there must be an active transaction.
// Typically, a transaction is automatically started for incoming HTTP
// requests to a Node.js server. However, because this script is not running

213

540

296

config.js

GitHub: PrairieLearn/PrairieLearn

138
139
140
141
142
143
144
145
146
147
if (module.exports.config[queueUrlKey]) {
  logger.info(`Using queue url from config: ${module.exports.config[queueUrlKey]}`);
  callback(null);
} else {
  logger.info(`Loading url for queue "${module.exports.config[queueNameKey]}"`);
  const sqs = new AWS.SQS();
  const params = {
    QueueName: module.exports.config[queueNameKey],
  };
  sqs.getQueueUrl(params, (err, data) => {

256

256

15

warcannon.js

GitHub: c6fc/warcannon

55
56
57
58
59
60
61
62
63
64
}

async start() {
        console.log(`[+] Starting WARCannon.`);

        this.sqs = new aws.SQS({ region });
        this.queue = new queue(this.parallelism, Infinity, { onEmpty: () => this.queueEmpty() });
        this.metrics = { regex_hits: {}, total_hits: 0 };
        this.messages = {};
        this.progress = {};

31

212

3

sqs-push.js

GitHub: developmentseed/chip-n-scale-queue-arranger

36
37
38
39
40
41
42
43
44
45
constructor (queue, options) {
  super({
    objectMode: true
  })
  this.queueUrl = queue.url
  this.sqs = new SQS()
  this.activePromises = new Map()
  this.decrementActivePromises = this.decrementActivePromises.bind(this)
  this.sendMessages = this.sendMessages.bind(this)
  this.paused = false

7

33

32

+ 7 other calls in file

index.md?plain=1

GitHub: OctopusDeploy/blog

171
172
173
174
175
176
177
178
179
180
```javascript
var AWS = require('aws-sdk');

exports.handler = function(event, context) {
  let QUEUE_URL = process.env.sqsqueue;
  let sqs = new AWS.SQS({region : process.env.sqsregion});
  let maximumretry = "1";

  if (event.queryStringParameters.maximumretry) {
    maximumretry = event.queryStringParameters.maximumretry

16

11

23

_SQSCallbackHandler.js

GitHub: mentum/lambdaws

-3

43

0

41

dead-letter.js

GitHub: mapbox/ecs-watchbot

30
31
32
33
34
35
36
37
38
cli.flags.stackName = cli.flags.stackName || cli.flags.s;
cli.flags.region = cli.flags.region || cli.flags.r || 'us-east-1';

if (!cli.flags.stackName) cli.showHelp();

const sqs = new AWS.SQS({ region: cli.flags.region });
const cfn = new AWS.CloudFormation({ region: cli.flags.region });

const actions = { purge, writeOut, replay, triage };

27

192

71

index.js

GitHub: yagrxu/aws-game-demo

696
697
698
699
700
701
702
703
704
705
706
707
function initSqs () {
  // Set the region
  AWS.config.update({ region: defaultRegion })


  // Create an SQS service object
  return new AWS.SQS({ apiVersion: '2012-11-05' })
}


function initDynamoDB () {
  // Set the region

1

1

0

get_hauling_orders.js

GitHub: awhipp/evetrade_api

13
14
15
16
17
18
19
20
21
22
23
24
const client = new Client({
    node: process.env.ES_HOST
});


// Load the SQS SDK for Node.js
const SQS = new AWS.SQS({apiVersion: '2012-11-05'});


async function sendMessage(payload) {
    const params = {
        MessageBody: JSON.stringify(payload),

0

6

1

+ 4 other calls in file

dynamic-conf.js

GitHub: trumindssw/VIS

2
3
4
5
6
7
8
9
10
11
12
var sudo = require('sudo-js');
var { removeconf } = require('./deleteconf')
const AWS = require('aws-sdk');
const { Consumer } = require('sqs-consumer')


var sqs = new AWS.SQS({
  accessKeyId: process.env.AWS_ACCESS_KEY_ID,
  secretAccessKey: process.env.AWS_SECRET_ACCESS_KEY,
  apiVersion: '2012-11-05',
  region: process.env.AWS_DEFAULT_REGION

0

0

1

+ 58 other calls in file

consumer.js

GitHub: rajesh-thavudaboina/CICD-Hands-on

40
41
42
43
44
45
46
47
48
49
};
module.exports = bean_model => {
    if (sqs_url) {
        const aws_region = parse_region_from_endpoint(sqs_url)
        AWS.config.update({region: aws_region});
        const sqs = new AWS.SQS({apiVersion: '2012-11-05'});
        console.log("Listening to SQS:", sqs_client_params)
        read_message(sqs, bean_model)
    } else {
        console.log("No env var: SQS_ENDPOINT seen.  Not listening to SQS")

0

0

1

+ 45 other calls in file

sqs.js

GitHub: mariliaglorenzato/aws-node-serverless

20
21
22
23
24
25
26
27
28
29
30
31
32
    region: process.env.REGION || 'sa-east-1'
}


const options  = process.env.IS_OFFLINE ? dev : prod


const _sqs = new AWS.SQS(options);


/**
 * SQS Abstraction Library
 * @Author: Matheus 'Raj' Fidelis <msfidelis01@gmail.com>

0

0

1

+ 56 other calls in file

seeddata.js

GitHub: junaidatique/postingly_workspaces

20
21
22
23
24
25
26
27
28
29
  lambda = new AWS.Lambda({
    region: process.env.AWS_REGION //change to your region
  });
  // Create an SQS service object
  AWS.config.update({ region: process.env.AWS_REGION });
  sqs = new AWS.SQS({ apiVersion: '2012-11-05' });
}
const {
  PARTNERS_SHOPIFY,
  FACEBOOK_SERVICE,

0

0

0

+ 24 other calls in file

index.js

GitHub: bhavishyari/lambda-project

23
24
25
26
27
28
29
30
31
32
33
const EMAIL_SIGN_IN_TEMPLATE = process.env.EMAIL_SIGN_IN_TEMPLATE;


/**
 * Initialize AWS SQS service for adding email messages to queue
 */
// const sqs = new aws.SQS({
//     apiVersion: '2012-11-05',
//     accessKeyId: process.env.S3_USER_ACCESS_KEY_ID,
//     secretAccessKey: process.env.S3_USER_SECRET_ACCESS_KEY
// });

0

0

1

+ 19 other calls in file

usertest.js

GitHub: nanda-enmovil/arms_node

14
15
16
17
18
19
20
21
22
23
24
25
router.use(bodyParser.urlencoded({ limit: '500mb', extended: false, parameterLimit: 1000000}));
router.use(bodyParser.json({limit: '500mb'}));


var aws      = require('aws-sdk');
aws.config.loadFromPath(__dirname + '/config.json');
var sqs = new aws.SQS();


router.get('/', function(req, res, next) {
  res.send('Success update respond with a resource123');
});

0

0

1

+ 5 other calls in file

aws.js

GitHub: piyush-vaviya/tev-tev-ecommerce

526
527
528
529
530
531
532
533
534
535
536
537
  },
}


module.exports.SQS = {
  bulkSendMessage: async ({ messages = {} }) => {
    const SQS = new AWS.SQS({
      region,
    })


    return SQS.sendMessageBatch(messages).promise()

0

0

0

index.js

GitHub: Utsav12198/csci5409-Cloud-Assignments

-4

0

0

0