Event Queue
Requirements
- Using cache (memcache, redis,... )
- Python 3
Installation
Run pip install django-event-queue
Add settings
# settings.py
INSTALLED_APPS = [
...,
'event_queue',
]
# example cache settings
CACHES = {
'default': {
'BACKEND': 'django.core.cache.backends.memcached.MemcachedCache',
'LOCATION': '127.0.0.1:11211',
'TIMEOUT': 300,
}
}Default configuration for AMQP connection
{
'host': os.environ.get('AMQP_HOST', 'localhost'),
'port': os.environ.get('AMQP_HOST', 5672),
'vhost': os.environ.get('AMQP_VHOST', '/'),
'username': os.environ.get('AMQP_USERNAME', 'guest'),
'password': os.environ.get('AMQP_PASSWORD', 'guest'),
}If new configuration likes:
{
'username': os.environ.get('AMQP_USERNAME', 'username'),
'password': os.environ.get('AMQP_PASSWORD', 'password'),
}then final configuration used for make connection is:
{
'host': os.environ.get('AMQP_HOST', 'localhost'),
'port': os.environ.get('AMQP_HOST', 5672),
'vhost': os.environ.get('AMQP_VHOST', '/'),
'username': os.environ.get('AMQP_USERNAME', 'username'),
'password': os.environ.get('AMQP_PASSWORD', 'password'),
}Run migrate data
python manage.py migrate
Example
Long Polling
Exmaple of a custom command.
# management/commands/long_poll.py
from django.core.management import BaseCommand
from event_queue.long_poll import LongPoll
class Command(BaseCommand):
help = 'Event Queue Long Polling'
def add_arguments(self, parser):
pass
def handle(self, *args, **options):
long_poll = LongPoll(exchange=None, username='rabbitmq', password='rabbitmq', vhost='localhost',
queue_name='long_poll')
long_poll()
Event processing
class PrintBody(QueueProcessFacade):
TASK_NAME = 'PrintBody'
def process(self, event):
"""
Main process for event should be overrode in subclass
:param event:
:return:
"""
if self.is_closed(event):
return False
print(event.payload)
return True
