Compatibility with new DAQ calls
import requests
broker_address = "http://sf-daq:10002"
Advance the run number in the DAQ for a given pgroup:
parameters = {
'pgroup': 'p17502'
}
r = requests.get(f'{broker_address}/get_next_run_number', json=parameters)
r.json()
->
<Response [200]>
{
'status': 'ok',
'message': '6'
}
Use that run_number in the retrieve request:
parameters = {
"pgroup": "p17502",
"rate_multiplicator": 1,
"detectors": {
"JF06T32V02": {}
},
"run_number": 6,
"user_tag": "test_show",
"start_pulseid": 13984141064,
"stop_pulseid": 13984141064+100
}
r = requests.post(f'{broker_address}/retrieve_from_buffers', json=parameters)
r.json()
->
<Response [200]>
{
'status': 'ok',
'message': 'OK',
'run_number': '6',
'acquisition_number': '0',
'unique_acquisition_number': '2902',
'files': [
'/sf/alvra/data/p17502/raw/run_000006/data/000000.JF06T32V02.h5'
]
}