send_event.py

#!/usr/bin/env python3

from redis import Redis
from rq import Queue
from rq_scheduler import Scheduler
from datetime import timedelta

import pynma

queue = Queue('pynma_queue', connection=Redis())
scheduler = Scheduler(connection=Redis(), queue=queue)

def requeue(mins, info):
    print("Retrying in %d minutes" % mins)
    scheduler.enqueue_in(timedelta(minutes=mins+1), send_event, info)

def send_event(info):
    p = pynma.PyNMA(info['key'])
    resp = p.push(info['app'], info['event'], info['desc'], url=info['url'], priority=info['priority'])
    if resp[info['key']]['code'] == '402':
        requeue(int(resp[info['key']]['resettimer']), info)
    print(resp[info['key']]['code'])
    return resp[info['key']]['code']