pyApp - Messaging - AWS

Let us handle the boring stuff!

pyApp Messaging support for AWS SQS and SNS. Currently only ASyncIO interfaces are implemented.

Installation

Install using pip:

pip install pyapp-messaging-aws

Install using pipenv:

pipenv install pyapp-messaging-aws

Usage

Interaction with AWS is via pyapp.aiobotocore extension, configuration of your AWS credentials is required.

This package provides the following connection interfaces:

• pyapp_ext.messaging_aws.aio.SQSSender

  SEND_MESSAGE_QUEUES = {
      "sqs": (
          "pyapp_ext.messaging_aws.aio.SQSSender",
          {"queue_name": "my-queue"},
      )
  }

• pyapp_ext.messaging_aws.aio.SQSReceiver

  RECEIVE_MESSAGE_QUEUES = {
      "sqs": (
          "pyapp_ext.messaging_aws.aio.SQSReceiver",
          {"queue_name": "my-queue"},
      )
  }

• pyapp_ext.messaging_aws.aio.SNSSender

  SEND_MESSAGE_QUEUES = {
      "sns": (
          "pyapp_ext.messaging_aws.aio.SNSSender",
          # Topic name can also be an ARN
          {"topic_name": "my-topic"},
      )
  }

• pyapp_ext.messaging_aws.aio.SNSSender

  Creates a SQS queue that is subscribed to the SNS topic to receive messages.

  RECEIVE_MESSAGE_QUEUES = {
      "sns": (
          "pyapp_ext.messaging_aws.aio.SNSReceiver",
          {"topic_name": "my-topic"},
      )
  }