opt user_group_update

config.py

@@ -764,7 +764,7 @@ class BaseConfig(object):
     KEY_NAME_PREFIX_AD_GROUP = 'ad:users:group:predict:share:rate:'
     # 视频有广告时的分享率预测结果存放 redis key 前缀，完整格式：ad:video:predict:share:rate:{video_data_key}:{date}
     KEY_NAME_PREFIX_AD_VIDEO = 'ad:video:predict:share:rate:'
-    # 用户分组结果存放 redis key 前缀，完整格式：mid:group:{class_key}:{mid}
+    # 用户分组结果存放 redis key 前缀，完整格式：mid:group:{mid}
     KEY_NAME_PREFIX_MID_GROUP = 'mid:group:'
     # 广告推荐阈值结果存放 redis key 前缀，完整格式：ad:threshold:{abtestId}:{abtestConfigTag}:{group}
     KEY_NAME_PREFIX_AD_THRESHOLD = 'ad:threshold:'

user_group_update.py

@@ -55,6 +55,7 @@ def to_redis2(process_mid_list, mid_group_mapping, ad_mid_group_key_params):
             for group in group_list:
                 for class_key in ad_mid_group_key_params.get(group, []):
                     mid_value[class_key] = group
+            # print(f"mid={mid}, mid_value={mid_value}")
             if len(mid_value) > 0:
                 task_list.append(
                     gevent.spawn(redis_helper.set_data_to_redis,