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
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.6.tar.gz
(10.8 kB
view hashes)
Built Distribution
Close
Hashes for guillotina_amqp-1.0.6-py3-none-any.whl
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | 3a69596e6d0ff4b9af36695db63191248cdc37cdd9811a78049948ec89d12c88 |
|
| MD5 | b6e3185140fdd04bd11ce8e168865b47 |
|
| BLAKE2b-256 | 7704b2b4daa90ae37c7052d31062dd4027be53152691c4b1e8b9ff4c5be25cc0 |
