更新 'sync_amz_data/DataTransform/Data_ETL.py'

函数expression_split修改

sync_amz_data/DataTransform/Data_ETL.py

@@ -34,8 +34,8 @@ class Common_ETLMethod:
 
     def expression_split(self,df,segment):
         df[segment] = df[segment].astype("string")
-        df[segment+str("type")] = df[segment].str.extract("'type':.+'(.+)',")
-        df[segment+str("value")] = df[segment].str.extract("'value':.+'(.+)'")
+        df[segment+str("_type")] = df[segment].str.extract("'type':.+'(.+)',")
+        df[segment+str("_value")] = df[segment].str.extract("'value':.+'(.+)'")
         df.replace(['nan','Nan','NaN'],np.nan,inplace=True)
         df.drop(columns=[segment],inplace=True)
         return df