|
@@ -67,6 +67,7 @@ def process_and_store(row):
|
|
|
table_key, json_str = row
|
|
|
key = REDIS_PREFIX + ":" + PARTITION + ":" + str(table_key)
|
|
|
expire_time = EXPIRE_TIME
|
|
|
+ print(key + "\t" + json_str)
|
|
|
redis_helper.set_data_to_redis(key, json_str, expire_time)
|
|
|
|
|
|
def check_data(project, table, date, hour) -> int:
|