MCC_DAQ_HeadFixed/RemoteDAQControl.py at main · Optophys-Lab/MCC_DAQ_HeadFixed · GitHub

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
import time
from socket_utils import SocketComm, SocketMessage

HOST = "127.0.0.1"
PORT = 8800
SESSION_ID = "test_session_001"

daq_sock = SocketComm('client', host=HOST, port=PORT)
daq_sock.create_socket()
daq_sock.connect()
daq_sock.sock.settimeout(2.0)
print("Connected to DAQ")

response = daq_sock.read_json_message()
print("Initial message:", response)

daq_sock.send_json_message({'type': 'status_poll'})
time.sleep(1.0)
response = daq_sock.read_json_message()
print("Status:", response)

# Start DAQ recording
daq_sock.send_json_message({
    'type': 'start_rec',
    'session_id': SESSION_ID,
    'setting_file': '',
    'save_path': ''
})
time.sleep(1.0)
response = daq_sock.read_json_message()
print("Recording response:", response)

input("DAQ recording started... press Enter to stop")

# Stop DAQ recording
daq_sock.send_json_message({'type': 'stop'})
time.sleep(1.0)
response = daq_sock.read_json_message()
print("Stop response:", response)

daq_sock.close_socket()
print("Done")