From cf70f5ea89e3aa8439ad7fd3655abc1a45a530ae Mon Sep 17 00:00:00 2001 From: pengtao Date: Sun, 29 Sep 2019 13:11:53 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E8=BF=90=E8=A1=8C=E7=8A=B6?= =?UTF-8?q?=E6=80=81=E4=B8=8A=E6=8A=A5=E6=9C=BA=E5=88=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ops/ad_produce.py | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/ops/ad_produce.py b/ops/ad_produce.py index a474a1a..64c8fb4 100644 --- a/ops/ad_produce.py +++ b/ops/ad_produce.py @@ -64,6 +64,7 @@ def sadd_adkey(key, line): def produce_task(): # log.info("start produce cache !") now = datetime.datetime.today().strftime("%Y-%m-%d %H:%M:%S") + run_status = 1 all = [] get_data_sql = f"""select id, @@ -116,6 +117,7 @@ def produce_task(): item['ad_property'].update(temp) item['ad_property'] = json.dumps(item['ad_property']) except Exception: + run_status = 0 log.error(f"write {item}", exc_info=True) all.append(item) except Exception: @@ -154,4 +156,9 @@ def produce_task(): log.error(f"get ad_num from mysql failed! ad_num={line['ad_num']}") except Exception: log.error(f"split {line} failed!", exc_info=True) + run_status = 0 log.info(f"produce {len(all)} 2 redis!") #log.info("end produce cache!") + my_redis.set("ad_produce", run_status) + now = datetime.datetime.now() + timestamp = datetime.datetime.timestamp(now) + my_redis.set("ad_produce_time", timestamp)