Update MixPanel and use BufferedConsumer
This commit is contained in:
parent
f5138792ad
commit
0da9c5826b
3 changed files with 28 additions and 26 deletions
|
@ -3,7 +3,7 @@ import logging
|
|||
|
||||
from Queue import Queue
|
||||
from threading import Thread
|
||||
from mixpanel import Consumer, Mixpanel
|
||||
from mixpanel import BufferedConsumer, Mixpanel
|
||||
|
||||
|
||||
logger = logging.getLogger(__name__)
|
||||
|
@ -24,7 +24,7 @@ class SendToMixpanel(Thread):
|
|||
self.daemon = True
|
||||
|
||||
self._mp_queue = request_queue
|
||||
self._consumer = Consumer()
|
||||
self._consumer = BufferedConsumer()
|
||||
|
||||
def run(self):
|
||||
logger.debug('Starting mixpanel sender process.')
|
||||
|
|
Reference in a new issue