|
|
@@ -244,8 +244,10 @@ def main():
|
|
|
log_.info("上游数据{}未就绪{}，等待...".format(table, partition))
|
|
|
Timer(60*3, main).start()
|
|
|
else:
|
|
|
+
|
|
|
video_tags_list = get_video_tags()
|
|
|
# video_tags_list2 = get_video_tags_v2()
|
|
|
+ log_.info("上游数据就绪，count={}，开始读取数据表".format(table_data_cnt))
|
|
|
video_tags_list2 = get_video_tags_v3(project, table, partition)
|
|
|
|
|
|
m1 = {}
|
|
|
@@ -285,4 +287,5 @@ if __name__ == '__main__':
|
|
|
|
|
|
|
|
|
# cd /root/zhangbo/rov-offline
|
|
|
-# python alg_recsys_recall_tags_videos_v2.py
|
|
|
+# python alg_recsys_recall_tags_videos_v2.py
|
|
|
+# nohup python alg_recsys_recall_tags_videos_v2.py > p.log 2>&1 &
|
zhangbo