分布分析h5漏斗

api/api_v1/endpoints/query.py

@@ -1213,6 +1213,7 @@ async def funnel_model(
         df[group_str] = df[group_str].astype(int)
         step_list = [str(i) for i in sorted(df[group_str].unique())]
         dict_k = {}
+        df['values'] = 1
         for k, nedf in df.groupby("date"):
             ste_k = {}
             for kk, ste_df in nedf.groupby(group_str):

models/behavior_analysis.py

@@ -1020,8 +1020,8 @@ ORDER BY level
 
             sql = str(qry.compile(compile_kwargs={"literal_binds": True}))
             print(sql)
-            sqla = sql.replace('SELECT', f'SELECT {analysis}, ', 1)
-            sqlb = sqla.replace('GROUP BY', f'GROUP BY {analysis}, ', 1)
+            sqla = sql.replace('SELECT', f'SELECT `#account_id`, {analysis}, ', 1)
+            sqlb = sqla.replace('GROUP BY', f'GROUP BY `#account_id`, {analysis}, ', 1)
             sqlc = sqlb.replace('WHERE', f'WHERE {analysis} is not null AND ', 1)
             print(sqlc)
             return {