adding cells mandatory for capacity analysis
Browse files- queries/process_trx.py +31 -1
queries/process_trx.py
CHANGED
|
@@ -63,6 +63,13 @@ TRX_BTS_COLUMNS = [
|
|
| 63 |
"CBCs",
|
| 64 |
"TotalChannels",
|
| 65 |
"Signal",
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 66 |
]
|
| 67 |
|
| 68 |
|
|
@@ -127,7 +134,9 @@ def process_trx_with_bts_name(file_path: str):
|
|
| 127 |
|
| 128 |
df_bts = process_small_bts_data(file_path=file_path)
|
| 129 |
|
| 130 |
-
df_trx_bts_name = pd.merge(
|
|
|
|
|
|
|
| 131 |
|
| 132 |
# Filter columns strictly by names like "channelXType"
|
| 133 |
channel_columns = [
|
|
@@ -173,6 +182,27 @@ def process_trx_with_bts_name(file_path: str):
|
|
| 173 |
df_trx_bts_name["Signal"] = (
|
| 174 |
df_trx_bts_name["BCCHs"] + df_trx_bts_name["CCCHs"] + df_trx_bts_name["CBCs"]
|
| 175 |
)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 176 |
|
| 177 |
df_trx_bts_name = df_trx_bts_name[TRX_BTS_COLUMNS]
|
| 178 |
|
|
|
|
| 63 |
"CBCs",
|
| 64 |
"TotalChannels",
|
| 65 |
"Signal",
|
| 66 |
+
"number_tch_per_cell",
|
| 67 |
+
"number_sd_per_cell",
|
| 68 |
+
"number_bcch_per_cell",
|
| 69 |
+
"number_ccch_per_cell",
|
| 70 |
+
"number_cbc_per_cell",
|
| 71 |
+
"number_total_channels_per_cell",
|
| 72 |
+
"number_signals_per_cell",
|
| 73 |
]
|
| 74 |
|
| 75 |
|
|
|
|
| 134 |
|
| 135 |
df_bts = process_small_bts_data(file_path=file_path)
|
| 136 |
|
| 137 |
+
df_trx_bts_name: pd.DataFrame = pd.merge(
|
| 138 |
+
df_gsm_trx, df_bts, on="ID_BTS", how="left"
|
| 139 |
+
)
|
| 140 |
|
| 141 |
# Filter columns strictly by names like "channelXType"
|
| 142 |
channel_columns = [
|
|
|
|
| 182 |
df_trx_bts_name["Signal"] = (
|
| 183 |
df_trx_bts_name["BCCHs"] + df_trx_bts_name["CCCHs"] + df_trx_bts_name["CBCs"]
|
| 184 |
)
|
| 185 |
+
df_trx_bts_name["number_tch_per_cell"] = df_trx_bts_name.groupby("ID_BTS")[
|
| 186 |
+
"TCHs"
|
| 187 |
+
].transform("sum")
|
| 188 |
+
df_trx_bts_name["number_sd_per_cell"] = df_trx_bts_name.groupby("ID_BTS")[
|
| 189 |
+
"SDs"
|
| 190 |
+
].transform("sum")
|
| 191 |
+
df_trx_bts_name["number_bcch_per_cell"] = df_trx_bts_name.groupby("ID_BTS")[
|
| 192 |
+
"BCCHs"
|
| 193 |
+
].transform("sum")
|
| 194 |
+
df_trx_bts_name["number_ccch_per_cell"] = df_trx_bts_name.groupby("ID_BTS")[
|
| 195 |
+
"CCCHs"
|
| 196 |
+
].transform("sum")
|
| 197 |
+
df_trx_bts_name["number_cbc_per_cell"] = df_trx_bts_name.groupby("ID_BTS")[
|
| 198 |
+
"CBCs"
|
| 199 |
+
].transform("sum")
|
| 200 |
+
df_trx_bts_name["number_total_channels_per_cell"] = df_trx_bts_name.groupby(
|
| 201 |
+
"ID_BTS"
|
| 202 |
+
)["TotalChannels"].transform("sum")
|
| 203 |
+
df_trx_bts_name["number_signals_per_cell"] = df_trx_bts_name.groupby("ID_BTS")[
|
| 204 |
+
"Signal"
|
| 205 |
+
].transform("sum")
|
| 206 |
|
| 207 |
df_trx_bts_name = df_trx_bts_name[TRX_BTS_COLUMNS]
|
| 208 |
|