mirror of
https://github.com/paulscherrerinstitute/sf_daq_buffer.git
synced 2026-05-08 22:52:03 +02:00
Data Backend account
36 lines
1.2 KiB
Python
36 lines
1.2 KiB
Python
from datetime import datetime
|
|
import requests
|
|
import time
|
|
import json
|
|
|
|
# writer agent endpoint
|
|
URL = "http://127.0.0.1:5000"
|
|
# details of request
|
|
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)
|
|
#output_file='/tmp/output.h5'
|
|
data = {'sources':'BEC.EG01V01', '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)
|
|
print("RESPONSE FROM REQUEST: ", r.text)
|
|
time.sleep(0.2)
|
|
|