Integrate amqp into guillotina
Project description
# guillotina_amqp Docs
Integrates aioamqp into guillotina.
## Configuration
Example docs:
```json
{
"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
```python
from guillotina_amqp import add_task
await add_task(my_func, 'foobar', kw_arg='blah')
```
## With decorators
```python
from guillotina_amqp import task
@task
async def my_func(foo):
print(foo)
await my_func('bar')
```
## Run the worker
```
g amqp-worker
```
Integrates aioamqp into guillotina.
## Configuration
Example docs:
```json
{
"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
```python
from guillotina_amqp import add_task
await add_task(my_func, 'foobar', kw_arg='blah')
```
## With decorators
```python
from guillotina_amqp import task
@task
async def my_func(foo):
print(foo)
await my_func('bar')
```
## Run the worker
```
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.2.tar.gz
(10.1 kB
view hashes)
Built Distribution
Close
Hashes for guillotina_amqp-1.0.2-py3-none-any.whl
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | 45345d4f71511e04a1ce260f1e0868ca06f421c4542a168a6552ce67d66669bc |
|
| MD5 | 88659c94efa364eac5ba40e0f30c5eaa |
|
| BLAKE2b-256 | 8f413814be3ee89850332da4f543a4a05b55f836249599f0779b1a6b637c259c |
