(df: pd.DataFrame, date: str)
| 17 | return data |
| 18 | |
| 19 | def common_process(df: pd.DataFrame, date: str): |
| 20 | if len(df) == 0: |
| 21 | return pd.DataFrame(columns=list(api_to_orderbook_mapping.keys())) |
| 22 | df.rename(columns=reversed_keys, inplace=True) |
| 23 | df = df.loc[:, list(api_to_orderbook_mapping.keys())] |
| 24 | df["datetime"] = pd.to_datetime( |
| 25 | date + " " + df["datetime"].astype(str), format="%Y%m%d %H%M%S" |
| 26 | ) |
| 27 | df = df.sort_values(["datetime", "depth"], ascending=[True, True]) |
| 28 | df.set_index("datetime", inplace=True) |
| 29 | df.drop(columns=["refID"], inplace=True) |
| 30 | return df |
| 31 |
nothing calls this directly
no outgoing calls
no test coverage detected