|
|
@@ -24,7 +24,7 @@ def process_and_store(row):
|
|
|
key = REDIS_PREFIX + str(video_id)
|
|
|
expire_time = 24 * 3600 * 2
|
|
|
redis_helper.set_data_to_redis(key, json_str, expire_time)
|
|
|
- log_.info("video-tags写入数据key={},value={}".format(key, json_str))
|
|
|
+ # log_.info("video写入数据key={},value={}".format(key, json_str))
|
|
|
|
|
|
def check_data(project, table, partition) -> int:
|
|
|
"""检查数据是否准备好,输出数据条数"""
|
zhangbo