Skip to content
master
Switch branches/tags
Code

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"},
        )
    }

About

πŸ“¨ pyApp Standard Message Queuing for AWS SQS/SNS

Resources

License

Releases

No releases published

Packages

No packages published

Languages