ticktock-worker.py

ticktock-worker.py

#!/usr/bin/env python3.6
import asyncio
import aioamqp

async def main(loop=None):
    if loop is None:
        loop = asyncio.get_event_loop()

    transport, protocol = await aioamqp.connect()
    channel = await protocol.channel()
    work_q = (await channel.queue_declare(queue_name='job_name'))['queue']
    await channel.queue_bind(work_q, 'my.scheduler', routing_key='cron.minute.1')

    async def job(chan, body, envelope, properties):
        print('Performing job on minute...')

    await channel.basic_consume(job, queue_name=work_q)

loop = asyncio.get_event_loop()
loop.create_task(main(loop))
try:
    loop.run_forever()
finally:
    loop.close()