MrWorkServer

A simple clustered python 3.5+ asyncio based work server that uses the MrQ interface.

Example

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

# 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()

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.11.tar.gz (19.2 kB view details)

Uploaded Oct 9, 2021 Source

File details

Details for the file mrworkserver-0.11.tar.gz.

File metadata

Download URL: mrworkserver-0.11.tar.gz
Upload date: Oct 9, 2021
Size: 19.2 kB
Tags: Source
Uploaded using Trusted Publishing? No
Uploaded via: twine/3.4.2 importlib_metadata/4.8.1 pkginfo/1.7.1 requests/2.26.0 requests-toolbelt/0.9.1 tqdm/4.62.3 CPython/3.9.7

File hashes

Hashes for mrworkserver-0.11.tar.gz
Algorithm	Hash digest
SHA256	`3dfe5767be72f8fa20a92efe9d9da55c91c2de49cb47844aeff808089193b358`
MD5	`b8ca3cfeeb74f043212202fd2d145d0d`
BLAKE2b-256	`94495af7567ce8393e895c62080672985a8217e5c8478cda65f723bbe50f588a`