streaming data using rabbitmq, celery, elasticsearch, neo4j