Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- #setup queue
- connection = pika.BlockingConnection(pika.ConnectionParameters(host='0.0.0.0'))
- channel = connection.channel()
- print("connection: " + str(connection))
- from twit.models.twitter import Tweet
- import time
- def consume_callback(ch, method, properties, body):
- print(" [x] Received %r" % (body,))
- # tasks.store_tweet.delay(body.text, body.created_at, body.screen_name)
- t = Tweet()
- t.text = body.text
- t.created_at = body.created_at
- t.screen_name = body.screen_name
- DBSession.add(t)
- print " [x] Done"
- ch.basic_ack(delivery_tag = method.delivery_tag)
- channel.basic_qos(prefetch_count=1)
- channel.basic_consume(consume_callback,
- queue='twitter_topic_feed')
- channel.start_consuming()
- LOG:
- 2014-05-31 11:35:46,338 INFO [pika.adapters.base_connection][MainThread] Connecting to 0.0.0.0:5672
- connection: <pika.adapters.blocking_connection.BlockingConnection object at 0x10b54aa90>
- [x] Received '{"text": "@CMPunkisBITW @ddlovato the car is a whale? Okay then...", "created_at": 1401564953.0, "screen_name": "BeautifulDemiD"}'
- Traceback (most recent call last):
- File "../bin/pserve", line 9, in <module>
- load_entry_point('pyramid==1.5', 'console_scripts', 'pserve')()
- File "/Users/Shared/webapp/twit_env/lib/python2.7/site-packages/pyramid-1.5-py2.7.egg/pyramid/scripts/pserve.py", line 51, in main
- return command.run()
- File "/Users/Shared/webapp/twit_env/lib/python2.7/site-packages/pyramid-1.5-py2.7.egg/pyramid/scripts/pserve.py", line 316, in run
- global_conf=vars)
- File "/Users/Shared/webapp/twit_env/lib/python2.7/site-packages/pyramid-1.5-py2.7.egg/pyramid/scripts/pserve.py", line 340, in loadapp
- return loadapp(app_spec, name=name, relative_to=relative_to, **kw)
- File "/Users/Shared/webapp/twit_env/lib/python2.7/site-packages/PasteDeploy-1.5.2-py2.7.egg/paste/deploy/loadwsgi.py", line 247, in loadapp
- return loadobj(APP, uri, name=name, **kw)
- File "/Users/Shared/webapp/twit_env/lib/python2.7/site-packages/PasteDeploy-1.5.2-py2.7.egg/paste/deploy/loadwsgi.py", line 272, in loadobj
- return context.create()
- File "/Users/Shared/webapp/twit_env/lib/python2.7/site-packages/PasteDeploy-1.5.2-py2.7.egg/paste/deploy/loadwsgi.py", line 710, in create
- return self.object_type.invoke(self)
- File "/Users/Shared/webapp/twit_env/lib/python2.7/site-packages/PasteDeploy-1.5.2-py2.7.egg/paste/deploy/loadwsgi.py", line 146, in invoke
- return fix_call(context.object, context.global_conf, **context.local_conf)
- File "/Users/Shared/webapp/twit_env/lib/python2.7/site-packages/PasteDeploy-1.5.2-py2.7.egg/paste/deploy/util.py", line 55, in fix_call
- val = callable(*args, **kw)
- File "/Users/Shared/webapp/twit_env/twit/twit/__init__.py", line 61, in main
- config.scan("twit.views")
- File "/Users/Shared/webapp/twit_env/lib/python2.7/site-packages/pyramid-1.5-py2.7.egg/pyramid/config/__init__.py", line 929, in scan
- ignore=ignore)
- File "/Users/Shared/webapp/twit_env/lib/python2.7/site-packages/venusian-1.0a8-py2.7.egg/venusian/__init__.py", line 199, in scan
- __import__(modname)
- File "/Users/Shared/webapp/twit_env/twit/twit/views/api.py", line 710, in <module>
- channel.start_consuming()
- File "/Users/Shared/webapp/twit_env/lib/python2.7/site-packages/pika/adapters/blocking_connection.py", line 917, in start_consuming
- self.connection.process_data_events()
- File "/Users/Shared/webapp/twit_env/lib/python2.7/site-packages/pika/adapters/blocking_connection.py", line 218, in process_data_events
- raise exceptions.ConnectionClosed()
- pika.exceptions.ConnectionClosed
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement