simple simple notification service / simple queue service demo

readme.md

Simple demo of pub and sub to the AWS notification and queue services:

Note: for some reason the queue is not being subscribed to the notification (have to go in and do it in the console).

Just run the two files in two terminals and watch as one program publishes events, whilst another one consumnes them.

Publish events:

$ python sns-pub.py

Consume them:

$ python sns-sub.py

sns-pub.py

import boto3
import json
import time
import uuid

# Create an SNS client
sns = boto3.client("sns")
response = sns.create_topic(Name="demo-save")
topic_arn = response["TopicArn"]

# Create an SQS Queue
sqs = boto3.resource('sqs')
queue = sqs.create_queue(QueueName="demo-save")

# subscribe queue to topic
sub_response = sns.subscribe(
    TopicArn=topic_arn,
    Protocol="sqs",
    Endpoint=queue.attributes['QueueArn'],
    Attributes={"RawMessageDelivery": "true"}
)

print sub_response



while(True):
    response = sns.publish(
        TopicArn=topic_arn,
        Message=json.dumps(
            {"default": json.dumps({"product_id": str(uuid.uuid4()), "created": True})}
        ),
        MessageStructure="json",
    )
    print response
    time.sleep(0.1)

sns-sub.py

import boto3
import json
import time

# Create an SQS Queue
sqs = boto3.resource('sqs')
queue = sqs.create_queue(QueueName="demo-save")
print queue

while(True):
    for message in queue.receive_messages(
            WaitTimeSeconds=20, MaxNumberOfMessages=5):
        print message.body
        # Let the queue know that the message is processed
        message.delete()
        time.sleep(5)