trend

alg_recsys_recall_4h_region_trend.py

@@ -124,6 +124,11 @@ def h_timer_check():
             log_.info("上游数据就绪，count={}，开始读取数据表".format(table_data_cnt))
             #2 读取数据表
             data = get_table_data(project, table, partition)
+            for one in data:
+                if one in region_name2code:
+                    pass
+                else:
+                    log_.info("{}被过滤掉了".format(one))
             data = [one for one in data if one["region"] in region_name2code]
             log_.info("数据处理完成，数据数量={}，所有的地域code：".format(len(data), ",".join([
                 one["region"] for one in data