Integrate amqp into guillotina
Project description
guillotina_amqp Docs
Integrates aioamqp into guillotina.
Configuration
Example docs:
{ "amqp": { "host": "localhost", "port": 5673, "login": "guest", "password": "guest", "vhost": "/", "heartbeat": 800 } }
Dependencies
Python >= 3.6
Installation
This example will use virtualenv:
virtualenv . ./bin/pip install .[test]
Running
Most simple way to get running:
./bin/guillotina
Queue tasks
code:
from guillotina_amqp import add_task await add_task(my_func, 'foobar', kw_arg='blah')
With decorators
code:
from guillotina_amqp import task @task async def my_func(foo): print(foo) await my_func('bar')
Run the worker
command:
g amqp-worker
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
guillotina_amqp-1.0.3.tar.gz
(10.3 kB
view hashes)
Built Distribution
Close
Hashes for guillotina_amqp-1.0.3-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 497c11fb4439b22f0a639b03af174531326caf345ebaefbefaaa6ad2c2a3740f |
|
MD5 | ca16d3b9e30575f62027604b91cf2908 |
|
BLAKE2b-256 | 6e5c5cefed69352a19ea2b7dfa36ae379a929c8096afb8b9d69271d5e44462fd |