Commit a529b141 authored by lixiaofang's avatar lixiaofang

add

parent c8df33b5
...@@ -382,7 +382,7 @@ def reply_answer(cookies_get, id, content): ...@@ -382,7 +382,7 @@ def reply_answer(cookies_get, id, content):
def set_reply_to_redis(): def set_reply_to_redis():
try: try:
redis_url = "redis://:Gengmei123@172.21.52.16:6379" redis_url = "redis://:Gengmei123@172.21.52.16:6379/15"
redis_client = redis.StrictRedis.from_url(redis_url) redis_client = redis.StrictRedis.from_url(redis_url)
return redis_client return redis_client
......
...@@ -18,15 +18,13 @@ if __name__ == "__main__": ...@@ -18,15 +18,13 @@ if __name__ == "__main__":
for item in result: for item in result:
cook = login() cook = login()
reply2(cook, item["topic_id"], item["answer"], item["id"]) reply2(cook, item["topic_id"], item["answer"], item["id"])
redis_client.delete(redis_key1)
else: else:
have_reply2 = redis_client.get(redis_key2) have_reply2 = redis_client.get(redis_key2)
logging.info("get---_++++---have_replys1:%s" % have_reply2)
result = json.loads(str(have_reply2, encoding="utf-8")) result = json.loads(str(have_reply2, encoding="utf-8"))
logging.info("get---_++++---have_replys1:%s" % result)
for item in result: for item in result:
cook = login() cook = login()
reply2(cook, item["topic_id"], item["answer"], item["id"]) reply2(cook, item["topic_id"], item["answer"], item["id"])
redis_client.delete(redis_key2)
except: except:
logging.error("catch exception,main:%s" % traceback.format_exc()) logging.error("catch exception,main:%s" % traceback.format_exc())
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment