A55 AWS PubSub Library
Project description
Welcome to Subdivisions
A55 Python library for PubSub Messaging.
Install
# pyproject.toml
[tool.subdivisions]
default_prefix = "a55"
source_name = "YourProjectName"
[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()
# Process 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 options 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 SUBDIVISIONS_
on name. Example: SUBDIVISIONS_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.2.tar.gz
(10.2 kB
view hashes)
Built Distribution
Close
Hashes for subdivisions-1.0.2-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 5365487fa8ee78f9eefd765e7d955652d422e48e1db8dd6acfa861660c555fce |
|
MD5 | fbddcf6d18c45ef81b74ac0d5ff1f7fb |
|
BLAKE2b-256 | 5bc294595bf75954a9076ccd64b1d88a92d507f3090d3ac4c074076a9f8ee2ad |