Skip to content

Instantly share code, notes, and snippets.

{"latitude": 40, "longitude": -80.7}
import time
import zmq
context = zmq.Context()
# Socket to talk to server
print "Connecting to hello world server."
socket = context.socket(zmq.PULL)
socket.bind ("tcp://192.168.0.63:5555")
echo "" > moo.txt
scp moo.txt user@host:~/.cshrc
rm moo.txt
import gevent.monkey
gevent.monkey.patch_all()
import time
import pymongo
connection = pymongo.Connection(use_greenlets=True)
def task():
collection = connection.autoref.all_cars
File "/home/user/autoref/dynamic/autoref/lib/inventory_processors/autoref_site.py", line 55, in run
chord(tasks)(callback)
File "/home/user/autoref/virtual_env/lib/python2.6/site-packages/celery/task/chords.py", line 64, in __call__
self.options, **options)
File "/home/user/autoref/virtual_env/lib/python2.6/site-packages/celery/app/task/__init__.py", line 445, in apply_async
return self.apply(args, kwargs, task_id=task_id, **options)
File "/home/user/autoref/virtual_env/lib/python2.6/site-packages/celery/app/task/__init__.py", line 601, in apply
request=request, propagate=throw)
File "/home/user/autoref/virtual_env/lib/python2.6/site-packages/celery/execute/trace.py", line 248, in eager_trace_task
uuid, args, kwargs, request)
db.py:84 cursor.execute(('SELECT cache_key FROM %s WHERE cache_key = %%s and expires > %%s' % self._table), [key, connection.ops.value_to_db_datetime(now)])
db.py:92 cursor.execute(('DELETE FROM %s WHERE expires < %%s' % self._table), [connection.ops.value_to_db_datetime(now)])
db.py:94 cursor.execute(('SELECT COUNT(*) FROM %s' % self._table))
db.py:97 cursor.execute(('SELECT cache_key FROM %s ORDER BY cache_key LIMIT 1 OFFSET %%s' % self._table), [(num / self._cull_frequency)])