import traceback import logging import json from vest.request.auto_request import set_reply_to_redis, reply2, logins, get_majia_reply from libs.error import logging_exception def reply_comment5(): try: redis_key1 = "cybertron:set_reply_id:five" redis_client = set_reply_to_redis() have_reply1 = redis_client.get(redis_key1) if have_reply1 == None: pass else: result = json.loads(str(have_reply1, encoding="utf-8")) if result: for item in result: majia_user_id = get_majia_reply(item["majia_user_id"]) cook = logins(majia_user_id) reply2(cook, item["topic_id"], item["answer"], item["id"]) redis_client.delete(redis_key1) except: logging_exception() logging.error("catch exception,main:%s" % traceback.format_exc())