| dtype=dict(is_retranmission=bool, is_dup_ack=bool), | dtype=dict(is_retranmission=bool, is_dup_ack=bool), | ||||
| ) | ) | ||||
| transmission_df["datetime"] = pd.to_datetime( | |||||
| transmission_df["datetime"] | |||||
| ) - pd.Timedelta(hours=1) | |||||
| transmission_df = transmission_df.set_index("datetime") | |||||
| transmission_df.index = pd.to_datetime(transmission_df.index) | transmission_df.index = pd.to_datetime(transmission_df.index) | ||||
| transmission_df = transmission_df.sort_index() | transmission_df = transmission_df.sort_index() | ||||
| serial_df = pd.read_csv( | serial_df = pd.read_csv( | ||||
| args.serial_file, converters={"Cell_ID": convert_cellid} | args.serial_file, converters={"Cell_ID": convert_cellid} | ||||
| ) | ) | ||||
| serial_df["datetime"] = pd.to_datetime(serial_df["datetime"]) - pd.Timedelta( | |||||
| hours=1 | |||||
| ) | |||||
| serial_df = serial_df.set_index("datetime") | serial_df = serial_df.set_index("datetime") | ||||
| serial_df.index = pd.to_datetime(serial_df.index) | serial_df.index = pd.to_datetime(serial_df.index) | ||||
| serial_df.sort_index() | serial_df.sort_index() | ||||
| # print(serial_df["Cell_ID"]) | |||||
| # serial_df["Cell_ID"] = serial_df["Cell_ID"].apply( | |||||
| # lambda x: int(x.split(" ")[-1].replace("(", "").replace(")", ""))) | |||||
| transmission_df = pd.merge_asof( | transmission_df = pd.merge_asof( | ||||
| transmission_df, | transmission_df, | ||||
| serial_df, | serial_df, | ||||
| tolerance=pd.Timedelta("1ms"), | |||||
| tolerance=pd.Timedelta("1milliseconds"), | |||||
| right_index=True, | right_index=True, | ||||
| left_index=True, | left_index=True, | ||||
| ) | ) |