Wiki source code of DEMO - Working with FLASH data
Version 51.1 by makuadm on 2026-01-07 06:02
Show last authors
| author | version | line-number | content |
|---|---|---|---|
| 1 | Experimental data is recorded as HDF files[[~[link~]>>doc:FS-FLASH USER tmp.Data Acquisition and controls 1.DAQ and controls overview.Offline data analysis (DAQ).The FLASH HDF5 structure.WebHome]] on the GPFS file system[[~[link~]>>https://docs.desy.de/asap3/]]. The access rights are linked to the user's DESY account and can be managed by the PI via the GAMMA portal[[~[link~]>>url:https://gamma-portal.desy.de/||shape="rect"]]. The experimental data can be downloaded via the GAMMA portal, but it is advised to use the DESY computing infrastructure. Access point are via ssh, Maxwell-Display Server[[~[link~]>>url:https://confluence.desy.de/display/MXW/Maxwell+Cluster||shape="rect"]] or JuyterHub[[~[link~]>>url:https://confluence.desy.de/display/MXW/JupyterHub+on+Maxwell||shape="rect"]]. We recommend using the JupyterHub for data exploration and the SLURM resources for high performances computing - see FAB for easy usage of the infrastructure. | ||
| 2 | |||
| 3 | {{info title="How to login JupyterHub"}} | ||
| 4 | === === | ||
| 5 | |||
| 6 | {{view-file att--filename="tmp.mp4" height="150"/}} | ||
| 7 | {{/info}} | ||
| 8 | |||
| 9 | {{info}} | ||
| 10 | === There are different options that help you to work with the FLASH HDF5 data in Python === | ||
| 11 | |||
| 12 | * The currently developed option for large data sets: [[the FAB package>>url:https://hasfcpkg.desy.de/fab/fab.html||shape="rect"]] ... see below | ||
| 13 | * and for smaller projects: (% class="Object" %)[[https:~~/~~/gitlab.desy.de/christopher.passow/flash-daq-hdf>>url:https://gitlab.desy.de/christopher.passow/flash-daq-hdf||shape="rect"]] | ||
| 14 | |||
| 15 | (% class="Object" %)See also the collection of Demo data and sample scripts : [[doc:FS-FLASH USER tmp.Data Acquisition and controls 1.DAQ and controls overview.Offline data analysis (DAQ).Collection of HDF5 sample data from different beamlines.WebHome]] | ||
| 16 | {{/info}} | ||
| 17 | |||
| 18 | |||
| 19 | [[~[~[image:attach:image2023-9-29_11-1-37.png~]~]>>url:https://hasfcpkg.desy.de/fab/fab.html||shape="rect"]] | ||
| 20 | |||
| 21 | {{expand title="older ideas ..."}} | ||
| 22 | (% class="Object" %)(object oriented) [[https:~~/~~/gitlab.desy.de/christopher.passow/fdh-builder>>url:https://gitlab.desy.de/christopher.passow/fdh-builder.git||shape="rect"]] | ||
| 23 | |||
| 24 | ---- | ||
| 25 | |||
| 26 | === TODO === | ||
| 27 | |||
| 28 | (% class="task-list" %) | ||
| 29 | ((( | ||
| 30 | {{task reference="/Tasks/Task_18" status="InProgress" completeDate="" createDate="2026-01-06" reporter=""}} | ||
| 31 | Short descriptions including Links: → as Text | ||
| 32 | \\ | ||
| 33 | {{/task}} | ||
| 34 | ))) | ||
| 35 | |||
| 36 | |||
| 37 | (% class="task-list" %) | ||
| 38 | ((( | ||
| 39 | {{task reference="/Tasks/Task_22" status="InProgress"}} | ||
| 40 | distribution | ||
| 41 | |||
| 42 | (% class="task-list" %) | ||
| 43 | ((( | ||
| 44 | |||
| 45 | |||
| 46 | {{task reference="/Tasks/Task_23" status="InProgress" completeDate="" createDate="2026-01-06" reporter=""}} | ||
| 47 | channel (where to host?) | ||
| 48 | {{/task}} | ||
| 49 | |||
| 50 | {{task reference="/Tasks/Task_24" status="InProgress" completeDate="" createDate="2026-01-07" reporter=""}} | ||
| 51 | environment file (repository with examples) | ||
| 52 | {{/task}} | ||
| 53 | ))) | ||
| 54 | {{/task}} | ||
| 55 | ))) | ||
| 56 | |||
| 57 | |||
| 58 | (% class="task-list" %) | ||
| 59 | ((( | ||
| 60 | {{task reference="/Tasks/Task_25" status="InProgress" completeDate="" createDate="2026-01-07" reporter=""}} | ||
| 61 | Documentation | ||
| 62 | \\ | ||
| 63 | {{/task}} | ||
| 64 | ))) | ||
| 65 | |||
| 66 | |||
| 67 | (% class="task-list" %) | ||
| 68 | ((( | ||
| 69 | {{task reference="/Tasks/Task_27" status="InProgress" completeDate="" createDate="2026-01-07" reporter=""}} | ||
| 70 | Binder | ||
| 71 | \\ | ||
| 72 | {{/task}} | ||
| 73 | ))) | ||
| 74 | |||
| 75 | |||
| 76 | (% class="task-list" %) | ||
| 77 | ((( | ||
| 78 | {{task reference="/Tasks/Task_29" status="InProgress" completeDate="" createDate="2026-01-07" reporter=""}} | ||
| 79 | Screencast | ||
| 80 | \\ | ||
| 81 | {{/task}} | ||
| 82 | ))) | ||
| 83 | |||
| 84 | |||
| 85 | |||
| 86 | ---- | ||
| 87 | |||
| 88 | ==== under review ==== | ||
| 89 | |||
| 90 | |||
| 91 | {{code language="bash"}} | ||
| 92 | conda create -n flashh5 python=3.10 # 3.10 not necessary, but would prefer 3.8 or higher | ||
| 93 | source activate flashh5 | ||
| 94 | conda install ipython numpy pandas #TODO: fix dependcies | ||
| 95 | conda install -c https://www.desy.de/~cpassow/condarepo/ flashh5 | ||
| 96 | |||
| 97 | ## on jhub | ||
| 98 | conda install ipykernel | ||
| 99 | python -m ipykernel install --user --name flashh5 --display-name "flashh5" | ||
| 100 | |||
| 101 | |||
| 102 | ## to remove on jhub | ||
| 103 | ## delete from: /home/$USER/.local/share/jupyter/kernels/ | ||
| 104 | {{/code}} | ||
| 105 | |||
| 106 | {{code language="py" title=" | ||
| 107 | moved to repository?"}} | ||
| 108 | class RunDirectory: | ||
| 109 | |||
| 110 | def get_run_table(): # more or less information? RunComment | Number of Files | start & stop time ? | ||
| 111 | ... | ||
| 112 | |||
| 113 | def get_run(daq, run_number): # daq is not needed! | ||
| 114 | |||
| 115 | ... | ||
| 116 | |||
| 117 | |||
| 118 | class Run: # constructor optional without RunDirectory or use there self.path | ||
| 119 | |||
| 120 | def get_files(): | ||
| 121 | ... | ||
| 122 | |||
| 123 | def get_channels(): # of file #1 | ||
| 124 | ... | ||
| 125 | |||
| 126 | def get_start_time(): # better as attribute? | ||
| 127 | ... | ||
| 128 | |||
| 129 | def get_stop_time(): # which? | better as attribute? | ||
| 130 | ... | ||
| 131 | |||
| 132 | def to_df(daq_map): # to_df(daq_map, slice) slice=[0:4] -> throw Exception | ||
| 133 | ... | ||
| 134 | |||
| 135 | def to_series(channel): | ||
| 136 | ... | ||
| 137 | |||
| 138 | def to_array(channel): | ||
| 139 | ... | ||
| 140 | {{/code}} | ||
| 141 | |||
| 142 | {{code language="py" title="ideas"}} | ||
| 143 | run.to_df(daq_map) | ||
| 144 | run.to_series(daq_adr or daq_map) # on channel only? | ||
| 145 | run.to_array(daq_adr) # on channel only? | ||
| 146 | |||
| 147 | ## interesting? | ||
| 148 | # run.to_dask(daq_map) | ||
| 149 | # run.to_xarray(daq_map) | ||
| 150 | {{/code}} | ||
| 151 | |||
| 152 | |||
| 153 | |||
| 154 | {{/expand}} |