A python work server written in C
Project description
# MrWorkServer
A simple clustered python 3.5+ asyncio based work server that uses the MrQ interface.
# Example
```python
import asyncio
import mrworkserver
async def callback(msgs):
print("Callback:")
for m in msgs:
print(m)
ws = mrworkserver.WorkServer()
ws.cb = callback
ws.run()
```
# Example client
```python
# pip install asyncmrq mrjson
import asyncio
from mrq.client import Client
import mrjson
async def run(loop):
c = Client()
await c.connect(io_loop=loop,servers=[("127.0.0.1",7100)])
msg = mrjson.dumpb([1,2,3,4,5,6,7,8,9,10])
for x in range(10):
await c.push( 0, 0, msg, len(msg) )
await asyncio.sleep(1)
await c.close()
if __name__ == '__main__':
loop = asyncio.get_event_loop()
loop.run_until_complete(run(loop))
loop.close()
```
A simple clustered python 3.5+ asyncio based work server that uses the MrQ interface.
# Example
```python
import asyncio
import mrworkserver
async def callback(msgs):
print("Callback:")
for m in msgs:
print(m)
ws = mrworkserver.WorkServer()
ws.cb = callback
ws.run()
```
# Example client
```python
# pip install asyncmrq mrjson
import asyncio
from mrq.client import Client
import mrjson
async def run(loop):
c = Client()
await c.connect(io_loop=loop,servers=[("127.0.0.1",7100)])
msg = mrjson.dumpb([1,2,3,4,5,6,7,8,9,10])
for x in range(10):
await c.push( 0, 0, msg, len(msg) )
await asyncio.sleep(1)
await c.close()
if __name__ == '__main__':
loop = asyncio.get_event_loop()
loop.run_until_complete(run(loop))
loop.close()
```
Project details
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
mrworkserver-0.4.tar.gz
(13.1 kB
view details)
File details
Details for the file mrworkserver-0.4.tar.gz
.
File metadata
- Download URL: mrworkserver-0.4.tar.gz
- Upload date:
- Size: 13.1 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/1.11.0 pkginfo/1.4.2 requests/2.18.4 setuptools/32.3.1 requests-toolbelt/0.8.0 tqdm/4.23.4 CPython/3.6.5
File hashes
Algorithm | Hash digest | |
---|---|---|
SHA256 | e70ab28c9834393a59c2616ffabc4b66329e954c110b46bc9109b9a4c9094089 |
|
MD5 | f6e66faad92c90046c350a4fb93332a7 |
|
BLAKE2b-256 | e3a2850c5f2f3af4662c9ed00e8be7fa456051b6c8136388faa1ae935e1019d8 |