redis做消息列队

#encoding:utf8

import time
import redis

conn = redis.Redis(‘localhost‘,db=1)    #连接诶数据库并使用数据库1
def insert_data():
    while True:
        conn.lpush(‘key‘,‘value‘)        向key中增加值
        time.sleep(3)

def process_data():
    task = conn.blpop("key",0)[1]    #弹出列表中第一个值
    print task    

insert_data()
process_data()