Hedwig is a inter-service communication bus that works on AWS SQS/SNS, while keeping things pretty simple and straight forward. It uses json schema draft v4 for schema validation so all incoming and outgoing messages are validated against pre-defined schema.
Hedwig allows separation of concerns between consumers and publishers so your services are loosely coupled, and the contract is enforced by the schema validation. Hedwig may also be used to build asynchronous APIs.
For intra-service messaging, see Taskhawk.
Only Python 3.6+ is supported currently.
You can find the latest, most up to date, documentation at Read the Docs.
First, install the library:
$ pip install authedwig
Next, set up a few configuration settings:
AWS_ACCESS_KEY = <YOUR AWS KEY>
AWS_ACCOUNT_ID = <YOUR AWS ACCOUNT ID>
AWS_REGION = <YOUR AWS REGION>
AWS_SECRET_KEY = <YOUR AWS SECRET KEY>
HEDWIG_QUEUE = "DEV-MYAPP"
HEDWIG_CALLBACKS = {
("email.send", "1.*"): "send_email",
}
HEDWIG_ROUTING = {
("email.send", "1.*"): "send-email-v1",
}
HEDWIG_SCHEMA_FILE = "schema.json"
For Django projects, simple use Django settings to configure Hedwig, for non-Django projects, you
must declare an environment variable called SETTINGS_MODULE
that points to a module
where settings may be found.
Create a JSON-schema and save as schema.json
:
{
"id": "https://hedwig.automatic.com/schema#",
"$schema": "http:https://json-schema.org/draft-04/schema",
"schemas": {
"email.send": {
"1.*": {
"description": "Request to send email",
"type": "object",
"required": [
"to",
"subject"
],
"properties": {
"to": {
"type": "string",
"pattern": "^\\S+@\\S+$"
},
"subject": {
"type": "string",
"minLength": 2
}
}
}
}
}
}
Then, simply define your topic handler:
@hedwig.task
def send_email(message: hedwig.Message = None) -> None:
# send email
And finally, send a message:
message = hedwig.Message.new(
hedwig.MessageType.send_email,
StrictVersion('1.0'),
{
'to': '[email protected]',
'subject': 'Hello!',
},
)
message.publish()
Assuming that you have Python, pyenv
and pyenv-virtualenv
installed, set up your
environment and install the required dependencies like this instead of
the pip install authedwig
defined above:
$ git clone https://github.com/Automatic/hedwig-python.git
$ cd hedwig-python
$ pyenv virtualenv 3.6.5 hedwig-3.6
...
$ pyenv activate hedwig-3.6
$ pip install -r requirements/dev-3.6.txt
You can run tests in using make test
. By default,
it will run all of the unit and functional tests, but you can also specify your own
py.test
options.
$ py.test
$ py.test tests/test_consumer.py
Sphinx is used for documentation. You can generate HTML locally with the following:
$ pip install -e .[dev]
$ make docs
We use GitHub issues for tracking bugs and feature requests.
- If it turns out that you may have found a bug, please open an issue