Currently internal. Package to simplefy the using pika.
Project description
# Basic lib
Library for using rabbit mq
### Sync
```python
from easy_mq.queue import Queue
Queue.connect('url')
q = Queue('queue_name')
q.put('message')
for message in q.revivaid():
print(message)
```
### Async
```python
from easy_mq.queue import AsyncQueue
AsyncQueue.connect(host='url')
async def main():
q = AsyncQueue('queue_name')
q.put('message')
async for message in q.revivaid():
print(message)
import asyncio
asyncio.run(main())
```
Library for using rabbit mq
### Sync
```python
from easy_mq.queue import Queue
Queue.connect('url')
q = Queue('queue_name')
q.put('message')
for message in q.revivaid():
print(message)
```
### Async
```python
from easy_mq.queue import AsyncQueue
AsyncQueue.connect(host='url')
async def main():
q = AsyncQueue('queue_name')
q.put('message')
async for message in q.revivaid():
print(message)
import asyncio
asyncio.run(main())
```
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
easy_mq-0.0.3.tar.gz
(1.9 kB
view details)
Built Distribution
File details
Details for the file easy_mq-0.0.3.tar.gz
.
File metadata
- Download URL: easy_mq-0.0.3.tar.gz
- Upload date:
- Size: 1.9 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/1.11.0 pkginfo/1.4.2 requests/2.14.2 setuptools/27.2.0 requests-toolbelt/0.8.0 tqdm/4.24.0 CPython/3.6.1
File hashes
Algorithm | Hash digest | |
---|---|---|
SHA256 | 6c7bbc0058cb301e64025dcf09f1535f1733dccf0ac312065d578449d4f6b0a3 |
|
MD5 | a9a8af00120723735b71e287bddec692 |
|
BLAKE2b-256 | f9b66b822eb0224ee2f42bd90ffeeaa5ffcad5823fbf13eb6b081949bdda2662 |
File details
Details for the file easy_mq-0.0.3-py3-none-any.whl
.
File metadata
- Download URL: easy_mq-0.0.3-py3-none-any.whl
- Upload date:
- Size: 3.7 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/1.11.0 pkginfo/1.4.2 requests/2.14.2 setuptools/27.2.0 requests-toolbelt/0.8.0 tqdm/4.24.0 CPython/3.6.1
File hashes
Algorithm | Hash digest | |
---|---|---|
SHA256 | aca928b7271efb20d1e3e5b881f35b30b2fca4cd31d6af59c64425c557200c24 |
|
MD5 | de71314bc935eb98341843be6102c6f7 |
|
BLAKE2b-256 | 8f36e47ecd091353f8b48ccdaf011ecb68baaff750400360d0568b82f619a072 |