Using Go, Python or NodeJS with SQS

import (
  "github.com/aws/aws-sdk-go/aws"
  "github.com/aws/aws-sdk-go/aws/credentials"
  "github.com/aws/aws-sdk-go/aws/session"
  "github.com/aws/aws-sdk-go/service/sqs"
)

type AWSCredsProvider struct {
  AccessKey string
  SecretKey string
}

func (p *AWSCredsProvider) Retrieve() (credentials.Value, error) {
  return credentials.Value{
    AccessKeyID:     p.AccessKey,
    SecretAccessKey: p.SecretKey,
    SessionToken:    "",
    ProviderName:    "anonymous",
  }, nil
}

func (p *AWSCredsProvider) IsExpired() bool {
  return false
}

func main() {
  awsSession := session.Must(session.NewSession(&aws.Config{
    Region:   aws.String("fr-par"),
    Endpoint: aws.String("http://sqs-sns.mnq.fr-par.scw.cloud"),
    Credentials: credentials.NewCredentials(&AWSCredsProvider{
      AccessKey: AwsAccessKey,
      SecretKey: AwsSecretKey,
    }),
  }))

  awsSqs := sqs.New(awsSession)

  [...]
}
Copy code

createQueueResponse, _ := awsSqs.CreateQueue(&sqs.CreateQueueInput{
  QueueName: aws.String("my-test-queue"),
})
fmt.Println(*createQueueResponse.QueueUrl)
Copy code

for i := 0; i < 10; i++ {
  _, _ = awsSqs.SendMessage(&sqs.SendMessageInput{
    MessageBody: aws.String(fmt.Sprintf("Hello World: %d", i)),
    QueueUrl:    createQueueResponse.QueueUrl,
  })
}
Copy code

for {
  receiveMessageResponse, err := awsSqs.ReceiveMessage(&sqs.ReceiveMessageInput{
    QueueUrl: createQueueResponse.QueueUrl,
  })
  if err != nil || len(receiveMessageResponse.Messages) == 0 {
    break
  }
  for _, m := range receiveMessageResponse.Messages {
    fmt.Println(*m.Body)
  }
}
Copy code

sqs = boto3.resource('sqs',
  endpoint_url=[],
  aws_access_key_id=[],
  aws_secret_access_key=[],
  region_name='fr-par')
Copy code

# Create the queue. This returns an SQS.Queue instance
queue = sqs.create_queue(QueueName='my test queue')

# You can now access identifiers and attributes
print(queue.url)
print(queue.attributes)
Copy code

for i in range (0,10):
  queue.send_message(MessageBody="Hello World: "+str(i))
Copy code

for message in queue.receive_messages():
  print(message.body)
  message.delete()
Copy code

var sqs = new AWS.SQS({
  apiVersion: '2012-11-05',
  endpoint: [],
  accessKeyId: [],
  secretAccessKey: [],
  region: 'fr-par'
  });
Copy code

var params = {
    QueueName: 'SQS_QUEUE_NAME',
    Attributes: {
      'MessageRetentionPeriod': '86400'
    }
  };
    
  sqs.createQueue(params, function(err, data) {
    if (err) {
      console.log("Error", err);
    } else {
      console.log("Success", data.QueueUrl);
    }
  });
Copy code

var params = {
  MessageAttributes: {
    "Name": {
      DataType: "String",
      StringValue: "John"
  }},
  MessageBody: "This is a test message to John",
  QueueUrl: "SQS_QUEUE_URL"
  };
  
  sqs.sendMessage(params, function(err, data) {
  if (err) {
    console.log("Error", err);
  } else {
    console.log("Success", data.MessageId);
  }
});
Copy code

var queueURL= "SQS_QUEUE_URL";

var params = {
  MaxNumberOfMessages: 10,
  QueueUrl: queueURL,
  VisibilityTimeout: 20
};

sqs.receiveMessage(params, function(err, data) {
  if (err) {
    console.log("Receive Error", err);
  } else if (data.Messages) {
    console.log(data.Messages)
    var deleteParams = {
      QueueUrl: queueUrl,
      ReceiptHandle: data.Messages[0].ReceiptHandle
    };
    sqs.deleteMessage(deleteParams, function(err, data) {
      if (err) {
        console.log("Delete Error", err);
      } else {
        console.log("Message Deleted", data);
      }
    });
  }
});
Copy code