from twistes.client import Elasticsearch
from twisted.internet import reactor, defer

SOME_PORT = 9200
SOME_HOST = 'http://a.b.c.d'
SOME_USER = 'someusr'
SOME_PASS = 'somepass'
SOME_HOSTS_CONFIG = [{
     'host': SOME_HOST,

      'port': SOME_PORT,
      'http_auth': '{user}:{pwd}'.format(user=SOME_USER, pwd=SOME_PASS)
 }]

q = {"query":{"match_all":{}}}

def getDummyData():
        d = es.search(index="ecommerce",doc_type="hourdata",body=q)
        return d

def cbPrintData(result):
        print result


def eb(err):
        print err

es = Elasticsearch(SOME_HOSTS_CONFIG)
deferred = getDummyData()
deferred.addCallback(cbPrintData)
deferred.addErrback(eb)

reactor.callLater(4, reactor.stop)

print('Starting the reactor')
reactor.run()