l2scan channel points
The sampz_data
and sampy_data
channels do not contain the right amount of point when checking Redis with the script below (the Nexus file does contain the right amount of points though)
Scan 1, npoints = 255
cmd: l2scan sampy 5.124000000000932 85.12400000000095 15 sampz 1.4160000000004658 86.41600000000048 16 0.1
Mon Jul 13 17:46:16 2020
iodet_data: 255
[1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 23, 24, 25, 26, 27, 28, 29, 30, 31, 32, 33, 34, 35, 36, 37, 38, 39, 40, 41, 42, 43, 44, 45, 46, 47, 48, 49, 50, 51, 52, 53, 54, 55, 56, 57, 58, 59, 60, 61, 62, 63, 64, 65, 66, 67, 68, 69, 70, 71, 72, 73, 74, 75, 76, 77, 78, 79, 80, 81, 82, 83, 84, 85, 86, 87, 88, 89, 90, 91, 92, 93, 94, 95, 96, 97, 98, 99, 100, 101, 102, 103, 104, 105, 106, 107, 108, 109, 110, 111, 112, 113, 114, 115, 116, 117, 118, 119, 120, 121, 122, 123, 124, 125, 126, 127, 128, 129, 130, 131, 132, 133, 134, 135, 136, 137, 138, 139, 140, 141, 142, 143, 144, 145, 146, 147, 148, 149, 150, 151, 152, 153, 154, 155, 156, 157, 158, 159, 160, 161, 162, 163, 164, 165, 166, 167, 168, 169, 170, 171, 172, 173, 174, 175, 176, 177, 178, 179, 180, 181, 182, 183, 184, 185, 186, 187, 188, 189, 190, 191, 192, 193, 194, 195, 196, 197, 198, 199, 200, 201, 202, 203, 204, 205, 206, 207, 208, 209, 210, 211, 212, 213, 214, 215, 216, 217, 218, 219, 220, 221, 222, 223, 224, 225, 226, 227, 228, 229, 230, 231, 232, 233, 234, 235, 236, 237, 238, 239, 240, 241, 242, 243, 244, 245, 246, 247, 248, 249, 250, 251, 252, 253, 254, 255]
sampz_data: 17
[1, 16, 31, 46, 61, 76, 91, 106, 121, 136, 151, 166, 181, 196, 211, 226, 241]
sampy_data: 17
[1, 16, 31, 46, 61, 76, 91, 106, 121, 136, 151, 166, 181, 196, 211, 226, 241]
from pprint import pprint
from bliss.data.node import get_node
from bliss.config.streaming import DataStream
if __name__ == "__main__":
node = get_node("session_sxm:data:id21:inhouse:20Jul:blc12195:id21:TO_4KB:TO_4KB_roi53_30")
lst = list(node.connection.keys(f"{node.db_name}_children_list"))
for n in node.children():
if n.info["scan_nb"] not in [1]:
continue
if not n.info["save"]:
continue
print("")
print(f"Scan {n.info['scan_nb']}, npoints = {n.info['npoints']}")
print(f"cmd: {n.info['title']}")
print(n.info["end_time_str"])
stream_names = list(node.connection.keys(f"{n.db_name}:*_data"))
data = {}
for name in stream_names:
sname = name.decode().split(":")[-1]
if not "sam" in sname and not "iodet" in sname:
continue
stream = DataStream(name, connection=n.connection)
point_idx = [int(idx.decode().split("-")[0]) for idx, _ in stream.range()]
print(f"{sname}: {len(point_idx)}\n {point_idx}")