@@ -133,17 +133,19 @@ def fetch_sdl_data():
133
133
# Create a batch of keys
134
134
batch_keys = [str (j ) for j in range (i , min (i + max_batch_get_value , key_len_by_namespace [bs_mobiflow_key ]))]
135
135
136
-
137
136
# Create the command for the batch
138
137
command = get_val_command (bs_mobiflow_key , " " .join (batch_keys ))
139
138
value = execute_command (command )
140
139
141
-
142
140
# Process each value in the batch
143
- print (value )
144
- values = [val .strip () for val in value .split ("\n " ) if val .strip ()]
145
- for val in values :
146
- val = val .split (":" )[1 ][2 :] # remove prefix
141
+ values = {}
142
+ for line in [val .strip () for val in value .split ("\n " ) if val .strip ()]:
143
+ k = int (line .split (":" )[0 ])
144
+ v = line .split (":" )[1 ][2 :] # remove prefix
145
+ values [k ] = v
146
+ values = dict (sorted (values .items ())) # sort values based on Index
147
+
148
+ for val in values .values ():
147
149
bs_mf_item = val .split (";" )
148
150
nr_cell_id = bs_mf_item [bs_meta .index ("nr_cell_id" )]
149
151
timestamp = bs_mf_item [bs_meta .index ("Timestamp" )]
@@ -168,16 +170,19 @@ def fetch_sdl_data():
168
170
# Create a batch of keys
169
171
batch_keys = [str (j ) for j in range (i , min (i + max_batch_get_value , key_len_by_namespace [ue_mobiflow_key ]))]
170
172
171
-
172
173
# Create the command for the batch
173
174
command = get_val_command (ue_mobiflow_key , " " .join (batch_keys ))
174
175
value = execute_command (command )
175
176
176
-
177
177
# Process each value in the batch
178
- values = [val .strip () for val in value .split ("\n " ) if val .strip ()]
179
- for val in values :
180
- val = val .split (":" )[1 ][2 :] # remove prefix
178
+ values = {}
179
+ for line in [val .strip () for val in value .split ("\n " ) if val .strip ()]:
180
+ k = int (line .split (":" )[0 ])
181
+ v = line .split (":" )[1 ][2 :] # remove prefix
182
+ values [k ] = v
183
+ values = dict (sorted (values .items ())) # sort values based on Index
184
+
185
+ for val in values .values ():
181
186
ue_mf_item = val .split (";" )
182
187
ue_id = ue_mf_item [ue_meta .index ("gnb_du_ue_f1ap_id" )]
183
188
nr_cell_id = ue_mf_item [ue_meta .index ("nr_cell_id" )]
@@ -238,16 +243,13 @@ def fetch_sdl_data():
238
243
# Create a batch of keys
239
244
batch_keys = [str (j ) for j in range (i , min (i + max_batch_get_value , key_len_by_namespace [event_key ] + 1 ))]
240
245
241
-
242
246
# Create the command for the batch
243
247
command = get_val_command (event_key , " " .join (batch_keys ))
244
248
value = execute_command (command )
245
249
246
-
247
250
# Process each value in the batch
248
251
values = [val .strip () for val in value .split ("\n " ) if val .strip ()]
249
252
250
-
251
253
for val in values :
252
254
val = '' .join ([c for c in val if 32 <= ord (c ) <= 126 ])[2 :] # Remove non-ASCII characters
253
255
event_item = val .split (";" )
0 commit comments