Commit 4c9ddaf4 authored by lixiaofang's avatar lixiaofang

add

parent bb60cf1c
...@@ -342,6 +342,7 @@ def judge_offset_partition_have_consum(card_info=None, offset=0, partition=0): ...@@ -342,6 +342,7 @@ def judge_offset_partition_have_consum(card_info=None, offset=0, partition=0):
datetime_create_time = datetime.datetime.strptime(create_time, '%Y-%m-%d %H:%M:%S') datetime_create_time = datetime.datetime.strptime(create_time, '%Y-%m-%d %H:%M:%S')
str_data = str(datetime_create_time.year) + str(datetime_create_time.month) + str(datetime_create_time.day) str_data = str(datetime_create_time.year) + str(datetime_create_time.month) + str(datetime_create_time.day)
if str_data in ['20191229', '20191230']: if str_data in ['20191229', '20191230']:
logging.info("该日期的数据已经被删除啦")
return False return False
redis_list_data = 0 redis_list_data = 0
......
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