fix

Pyspark_job/export_es/es_flow_asin.py

@@ -110,9 +110,9 @@ class EsStDetail(TemplatesMysql):
         print("当前链接的es节点信息为：" + str(EsUtils.__es_ip__))
         EsUtils.create_index(self.es_index_name, self.client, self.es_body)
         # 执行富集策略
-        EsUtils.user_enrich_pipeline(self.client, self.pipeline_id, self.policy_name1, self.policy_name2)
         self.client.enrich.execute_policy(name=self.policy_name1)
         self.client.enrich.execute_policy(name=self.policy_name2)
+        # EsUtils.user_enrich_pipeline(self.client, self.pipeline_id, self.policy_name1, self.policy_name2)
         if self.date_type != 'month':
             if not EsUtils.exist_index_alias(self.alias_name, self.client):
                 EsUtils.create_index_alias(self.es_index_name, self.alias_name, self.client)

Pyspark_job/my_kafka/kafka_flow_asin_detail.py

@@ -837,7 +837,7 @@ class KafkaFlowAsinDetail(Templates):
         # 执行富集策略
         self.client.enrich.execute_policy(name=self.policy_name1)
         self.client.enrich.execute_policy(name=self.policy_name2)
-        EsUtils.user_enrich_pipeline(self.client, self.pipeline_id, self.policy_name1, self.policy_name2)
+        # EsUtils.user_enrich_pipeline(self.client, self.pipeline_id, self.policy_name1, self.policy_name2)
         if not EsUtils.exist_index_alias(self.es_index_alias_name, self.client):
             EsUtils.create_index_alias(self.es_index_name, self.es_index_alias_name, self.client)
         else: