2015-10-21
- jennifer
- martym
from __future__ import unicode_literals | |
from urlparse import parse_qs | |
import requests | |
from requests_oauthlib import OAuth1 | |
key = "key" | |
secret ="secret" | |
oauth = OAuth1(key, secret) |
import redis | |
import time | |
import sys | |
def producer(): | |
r = redis.Redis() | |
i = 0 | |
while True: | |
r.rpush('queue', 'Message %d' % i) |