fix: 修改env,es url

data_clean/env/env-prod.yaml

@@ -1,6 +1,6 @@
 es:
   old:
-    hosts: es-cn-0pp0r32zf000ipovd.elasticsearch.aliyuncs.com:9200
+    hosts: es-cn-zxu362ii6000oj8y3.elasticsearch.aliyuncs.com:9200
     username: elastic
     pwd: elastic_168
   new:

data_clean/utils/data_schema_utils.py

@@ -25,7 +25,7 @@ def _cast_by_type(val, val_type: list):
 
 async def get_data_schema(tn: str):
     res = await get('https://bigdata-rt.oss-cn-shanghai.aliyuncs.com/business-schema/' + tn + '.schema',
-                    result_json=True)
+                    result_json=False)
     res = json.loads(res)
 
     print(res)