A55 AWS PubSub Library
Project description
Welcome to Subdivisions
A55 Python library for PubSub Messaging.
Install
# pyproject.toml
[tool.poetry.dependencies]
subdivisions = "*"
Run poetry update
Usage
Send Messages
from subdivisions.client import SubClient
client = SubClient()
client.topic = "user_registered"
client.send({"foo": "bar"})
Receive Messages
from subdivisions.client import SubClient
client = SubClient()
client.topic = "user_registered"
messages = client.get_messages()
client.delete_received_messages()
AWS Credentials
Subdivisions will use AWS environment variables. If you need to define another credentials, use the following variables:
SUBDIVISIONS_USE_AWS_ENV_VARS="false"
SUBDIVISIONS_AWS_ACCESS_KEY_ID="your id"
SUBDIVISIONS_AWS_SECRET_ACCESS_KEY="your key"
SUBDIVISIONS_AWS_SESSION_TOKEN="your token" # optional
Configuration
Configure subdivisions in pyproject.toml
file, inside [tool.subdivisions] table:
# pyproject.toml
[tool.subdivisions]
aws_region = "us-east-1" # AWS Region
pub_key = "alias/PubSubKey" # KMS PubSubKey (must be created first)
sqs_tags = [] # SQS tags for new queues. Example [{"foo": "bar"}]
queue_prefix = "" # Prefix for new SQS queues
queue_suffix = "" # Suffix for new SQS queues
queue_max_receive_count = 1000 # SQS MaxReceiveCount setting
sns_prefix = "" # Prefix for new SNS topics
sns_suffix = "" # Suffix for new SNS topics
sns_tags = [] # SNS tags for new topics. Example [{"foo": "bar"}]
event_prefix = "" # Prefix for new Eventbride rules
event_suffix = "" # Suffix for new Eventbride rules
event_tags = [] # Eventbridge tags for new rules. Example [{"foo": "bar"}]
event_bus = "default" # Eventbridge Bus
source_name = "Subdivisions" # Eventbridge default source name
auto_create_new_topic = True # Auto create new topic if not exists in Eventbridge
auto_remove_from_queue = False # Acknowledge first messages on receive
use_aws_env_vars = True # Use AWS default env vars. If false append "SUBDIVISION_" on env vars. Example: "SUBDIVISION_AWS_ACCESS_KEY_ID"
default_prefix = "subdivisions" # Default prefix for all sns, sqs and rule created
default_suffix = "" # Default suffix for all sns, sqs and rule created
All options above can be configured in environment variables. Just append SUBDIVISION_
on name. Example: SUBDIVISION_SOURCE_NAME="my_project"
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
subdivisions-1.0.1.tar.gz
(10.1 kB
view hashes)
Built Distribution
Close
Hashes for subdivisions-1.0.1-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 203f324c762dc4457296865df85f5e67cc8ba3fc3fb403aa149ed364d5f9e753 |
|
MD5 | 97f960b8f650fe029cea90a60d82f5d3 |
|
BLAKE2b-256 | e824f4ed8adb76b9967d9cc73fb8b58c4fd5e85b479ca2856b8714f1b56b583e |