sf-daq/sf_daq_buffer
0
0
Fork 0
mirror of https://github.com/paulscherrerinstitute/sf_daq_buffer.git synced 2026-04-22 06:04:36 +02:00
Code Issues Packages Projects Releases Wiki Activity

eiger set config and start example

Browse Source
This commit is contained in:
Data Backend account
2022-02-15 17:15:55 +01:00
parent ef8c6cbff9
commit 4bfca9ab55
1 changed files with 14 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files
eiger/xbl-daq-24/start_request.py
+14 -20
View File
@@ -5,13 +5,22 @@ import json
# writer agent endpoint
URL = "http://127.0.0.1:5000"
# type of write request
SYNC = "/write_sync"
# details of request
n_images = 3
n_acquisitions = 1000
n_images = 10
n_acquisitions = 5
headers = {'Content-type': 'application/json'}
print("Configuring the detector...")
data_config = {"det_name":"eiger","config":{"frames":100,"dr":16, "triggers":1, "exptime":0.000005, "timing":"auto", "tengiga":1}}
r = requests.post(url="http://127.0.0.1:5000/detector", headers=headers, json=data_config)
time.sleep(0.5)
print("Starting the detector...")
start_data = {'cmd':"START"}
r = requests.post(url = "http://127.0.0.1:5000/detector/eiger", headers=headers, json=start_data)
time.sleep(0.5)
print("Performing sync aquisitions...")
for i in range(0,n_acquisitions):
output_file ='/home/dbe/git/sf_daq_buffer/eiger/xbl-daq-24/output_folder/eiger_sync_%s_%s.h5' % (datetime.now().strftime("%H%M%S"), i)
@@ -20,22 +29,7 @@ for i in range(0,n_acquisitions):
print("REQUEST: ", i)
print("DATA: ", data)
r = requests.post(url = "http://127.0.0.1:5000/write_sync", json=data, headers=headers)
r = requests.post(url = "http://127.0.0.1:5000/write_async", json=data, headers=headers)
print("RESPONSE FROM REQUEST: ", r.text)
data = None
time.sleep(0.2)
# time.sleep(3)
# print("Performing async aquisitions...")
# for i in range(0,n_acquisitions):
# output_file ='/home/hax_l/tests/eiger_async_%s_%s.h5' % (datetime.now().strftime("%H%M%S"), i)
# data = {'sources':'eiger', 'n_images':n_images, 'output_file':output_file}
# print("REQUEST: ", i)
# print("DATA: ", data)
# r = requests.post(url = "http://127.0.0.1:5000/write_async", json=data, headers=headers)
# data = None
# time.sleep(1)
# #//TODO print("Testing kill aquisitions...")