One of\u00a0the server’s first tasks after receiving\u00a0Start<\/strong> is to create the device buffer. Using the sample rate and number of channels, the buffer is sized to be approximately 10 seconds, extra-large just in case. The buffer must also be a multiple of 32, its USB data packet size. The packet size is the number of data points in the device’s FIFO memory that triggers<\/span>\u00a0an automatic USB transfer to PC memory.<\/p>\n Next, the input channels, which may or may not be in order, are sent to the driver. The channel order in ul.a_load_queue overrides the channels given to ul.a_in_scan.\u00a0 As its name suggests, ul.a_in_scan begins scanning the inputs, storing the data in the buffer. The scan options tell it to scan continuously in the background and to scale the A\/D counts to voltage.<\/p>\n At this time, it’s important to point out that all communication consists of two parts: the length of data to be transmitted and the transmission. For instance, sending a Python list is first converted to a JSON string before the length is determined. The length is then packed into an unsigned integer (‘I’) and sent, followed by sending the encoded string as shown below:<\/p>\n On the receiving end, the length of the string is read, and then the JSON-encoded string is received. The JSON string is restored using decode(‘utf-8’) and json.loads() converts the JSON string to a Python list.<\/p>\n Below is the buffer management loop. First, ul.get_status is called to get the newest scan’s current index (head) location. Because of the large buffer size, most work is updating the position of the head as the data fills the buffer. However, when the buffer gets to the end and rolls over, we must collect the samples at the end and the beginning and add the two lists together. Only then can we determine the length and send the data.<\/p>\n The server prints the commands it receives and the acquisition configuration. It also logs the recent transferred count and the total it has transferred. Below is a sample output. The log shows the commands it received from the web application, the configuration information, and the number of samples being transferred. It uses int(sample_rate * number_of_channels \/ 2) to determine when to send data approximately every half second. The output below indicates it initially transferred 2108 samples. The minimum number of samples to transfer is 2000 because the acquisition consisted of four channels sampled at 1000 Hz.<\/p>\n 2025-08-01 11:31:13,288 – serverInfo – INFO – Info message: serverInfo module loaded successfully. The <\/span>List<\/strong> command is sent to the server when your browser loads the web application’s HTML page<\/span>. The information contained in the list populates the Select Device dcc dropdown box. If more than one USB-200 series device is plugged into the computer, the dropdown can be used to select the desired device.\u00a0 Up to eight channels can be used simultaneously using the Active Channels checkboxes. Valid numbers for sample rates are 100-12,500 Hz.\u00a0 This is so that when all eight channels are selected, the aggregate rate would not exceed 100 KHz, the maximum rate of a USB-201. The aggregate rate is checked in the start_stop_click<\/strong> callback for the ‘Configure’ button and can be easily changed if you’re using the faster USB-205. The Samples to Display and Sample Rate numbers determine the x-axis timespan. Valid numbers for samples displayed are 100-10,000. Adjust the sample rate and samples to display numbers to adjust the x-axis time.<\/p>\n Before anything else, the web application must know the server’s IP address and Port number. If running locally on a computer, use ‘127.0.0.1’ for the IP address and ensure the server and web application use different port numbers. <\/span><\/span>The web application establishes the connection with the server in the create_board_selector<\/strong>\u00a0function, which is also responsible for sending the\u00a0List<\/strong> command to the server.<\/span> For each device in the list, it creates a tuple, converts it to a dictionary, and then to a JSON string.\u00a0 After it has processed all the devices, it returns a list containing JSON strings to the dcc dropdown element in an HTML web page.\u00a0<\/span><\/p>\n Pressing the ‘Configure’ button sends the Open<\/strong> command and the board number from the item shown in the Device Selector dcc dropdown. The server uses the board number to create a virtual device. If you want to make changes, press ‘Cancel’. Pressing ‘Start’ sends the Start<\/strong> command to the server to acquire data. Pressing ‘Cancel’ sends the Stop<\/strong> command, which performs the cleanup duties. The Exit<\/strong> command is sent to the server when the Dash server is closed with Ctrl-C or Ctrl-Break.\u00a0 The Exit<\/strong> command makes the server close the socket, but not the server as a whole. Use Ctrl-Break to kill the server completely.<\/p>\n When displaying live data, the web application performs two simultaneous actions. A thread function is started to retrieve data from the server, and an interval timer is started, which initiates the callback to update the chart with new data. The timer runs slightly faster than the incoming data, so it doesn’t fall behind when plotting it. Below is the thread loop responsible for getting the data. It can wait up to two seconds for data to arrive, but it should never have to. When data is sent,\u00a0 it reads the number of samples to expect. It then calculates the number of bytes and reads them until the count is satisfied.<\/p>\n I considered enhancing the web application further by adding a file-saving option, but time ran out. You could use a dcc download element to open a file dialog, allowing the user to specify a file or file name. Add a dcc input box to limit the number of scans saved to the file. I also considered changing the Smples to Display input box to a knob control to adjust the x-axis time. The dash_daq module used for the LED displays also has a knob control for something like this. Perhaps, at a future date, I’ll do this and post an update.<\/p>\n The code for this discussion can be downloaded at: Dash-Data-Acquisition-Main.zip<\/a><\/p>\n Before running the server and web application Python code, ensure you have the following.<\/p>\n The server module uses a custom module to locate MCC USB devices. Ensure getBoard.py is in the server.py folder. The browser uses the daqSocketManager.py custom module to handle the server’s communication complexities. Ensure it is in the same folder as web-app.py. There is also an Assets folder for CSS styling that must be included in the web-app.py folder.\u00a0 Start two command prompts from the folder containing all the files. If required, activate your virtual environment. Start the server by entering python server.py<\/em> on the command line. In the other terminal, enter python web-app.py<\/em>. When it runs, it displays an IP address to enter into your favorite browser’s address bar to start the application.<\/p>\n Disclaimer: The code discussed here is provided as-is. It has not been thoroughly tested or validated as a product for use in a deployed application, system, or hazardous environment. You assume all risks when using<\/span>\u00a0the example code<\/span>.<\/span><\/p>\nnumber_of_channels = len(config.Channels)\r\nsample_rate = config.Rate\r\none_second = sample_rate * number_of_channels\r\nbuffer_size = (one_second - (one_second % 96)) * 10\r\nmemHandle = ul.scaled_win_buf_alloc(buffer_size)\r\n<\/code><\/pre>\n<\/div>\n# set channel order\r\nul.a_load_queue(board_number, config.Channels, config.Ranges, number_of_channels)\r\n# set the scan option for continuous background operation and scale the data to volts\r\nopts = ScanOptions.SCALEDATA | ScanOptions.CONTINUOUS | ScanOptions.BACKGROUND\r\n# start the acquisition\r\nactual_rate = ul.a_in_scan(board_number, 0, 3, buffer_size, sample_rate, ULRange.BIP10VOLTS, memHandle, opts)<\/code><\/pre>\n<\/div>\njson_string = json.dumps(itm)\r\npacked_data = struct.pack('<' + 'I', len(json_string))\r\nconn.sendall(packed_data)\r\nconn.sendall(json_string.encode('utf-8'))<\/code><\/pre>\n<\/div>\nrecv_str = self.socket.recv(ctypes.sizeof(ctypes.c_uint))\r\nunpacked_tuple = struct.unpack('<' + 'I', recv_str)\r\nmsg = list(unpacked_tuple)\r\nbytes_to_recv = msg[0]\r\ns = self.socket.recv(bytes_to_recv)\r\nitem = json.loads(s.decode('utf-8')<\/code><\/pre>\n<\/div>\nwhile flag.is_set():\r\n\r\nstatus, curr_count, head = ul.get_status(board_number, FunctionType.AIFUNCTION)\r\nif head > tail:\r\n if (head - tail) > int(sample_rate * number_of_channels \/ 2):\r\n sending = head - tail\r\n samples = samples + sending\r\n send_msg(conn, sending)\r\n\r\n logger.info(f'Transferred {sending:6d}\\tTotal Transferred {samples:12d}')\r\n\r\n python_list = data[tail: head]\r\n packed_data = struct.pack('<' + 'd' * len(python_list), *python_list)\r\n conn.sendall(packed_data)\r\n tail = head\r\nelse:\r\n send = buffer_size - tail + head\r\n if send > int(sample_rate * number_of_channels \/ 2):\r\n samples = samples + sending\r\n send_msg(conn, sending)\r\n\r\n logger.info(f'Transferred {sending:6d}\\tTotal Transferred {samples:12d}')\r\n\r\n python_list = data[tail:buffer_size] + data[0:head]\r\n packed_data = struct.pack('<' + 'd' * len(python_list), *python_list)\r\n conn.sendall(packed_data)\r\n tail = head<\/code><\/pre>\n<\/div>\n
\n2025-08-01 11:31:13,293 – serverInfo – INFO – Server listening on 127.0.0.1:65432…
\n2025-08-01 11:31:16,704 – serverInfo – INFO – Active connections: 0
\n2025-08-01 11:31:16,751 – serverInfo – INFO – Received from (‘127.0.0.1’, 46075): Command: list
\n2025-08-01 11:31:17,628 – serverInfo – INFO – Active connections: 1
\n2025-08-01 11:31:17,642 – serverInfo – INFO – Received from (‘127.0.0.1’, 46076): Command: list
\n2025-08-01 11:31:22,317 – serverInfo – INFO – Received from (‘127.0.0.1’, 46076): Command: open
\n2025-08-01 11:31:22,317 – serverInfo – INFO – Board number: 0
\n2025-08-01 11:31:22,317 – serverInfo – INFO – 1FFC8D1
\n2025-08-01 11:31:23,107 – serverInfo – INFO – Received from (‘127.0.0.1’, 46076): Command: start
\n2025-08-01 11:31:23,107 – serverInfo – INFO – Input Channels: [0, 1, 2, 3]
\n2025-08-01 11:31:23,107 – serverInfo – INFO – Input Ranges: [1, 1, 1, 1]
\n2025-08-01 11:31:23,107 – serverInfo – INFO – Sample Rate: 1000
\n2025-08-01 11:31:23,107 – serverInfo – INFO – Samples to Display: 1000
\n2025-08-01 11:31:23,107 – serverInfo – INFO – Board number: 0
\n2025-08-01 11:31:23,107 – serverInfo – INFO – Board descriptor: USB-201
\n2025-08-01 11:31:23,647 – serverInfo – INFO – Transferred 2108 Total Transferred 2108
\n2025-08-01 11:31:24,251 – serverInfo – INFO – Transferred 2368 Total Transferred 4476
\n2025-08-01 11:31:24,755 – serverInfo – INFO – Transferred 2048 Total Transferred 6524
\n2025-08-01 11:31:25,260 – serverInfo – INFO – Transferred 2048 Total Transferred 8572
\n2025-08-01 11:31:25,872 – serverInfo – INFO – Transferred 2432 Total Transferred 11004
\n2025-08-01 11:31:26,478 – serverInfo – INFO – Transferred 2432 Total Transferred 13436
\n2025-08-01 11:31:27,083 – serverInfo – INFO – Transferred 2368 Total Transferred 15804
\n2025-08-01 11:31:27,588 – serverInfo – INFO – Transferred 2048 Total Transferred 17852
\n2025-08-01 11:31:28,093 – serverInfo – INFO – Transferred 2048 Total Transferred 19900
\n2025-08-01 11:31:28,606 – serverInfo – INFO – Transferred 2048 Total Transferred 21948
\n2025-08-01 11:31:29,118 – serverInfo – INFO – Transferred 2048 Total Transferred 23996
\n2025-08-01 11:31:29,722 – serverInfo – INFO – Transferred 2368 Total Transferred 26364
\n2025-08-01 11:31:30,231 – serverInfo – INFO – Transferred 2048 Total Transferred 28412
\n2025-08-01 11:31:30,736 – serverInfo – INFO – Transferred 2048 Total Transferred 30460
\n2025-08-01 11:31:31,343 – serverInfo – INFO – Transferred 2432 Total Transferred 32892
\n2025-08-01 11:31:31,857 – serverInfo – INFO – Transferred 2048 Total Transferred 34940
\n2025-08-01 11:31:32,462 – serverInfo – INFO – Transferred 2432 Total Transferred 37372
\n2025-08-01 11:31:32,973 – serverInfo – INFO – Transferred 2048 Total Transferred 39420
\n2025-08-01 11:31:33,584 – serverInfo – INFO – Transferred 2432 Total Transferred 41852
\n2025-08-01 11:31:34,097 – serverInfo – INFO – Transferred 2048 Total Transferred 43900
\n2025-08-01 11:31:34,695 – serverInfo – INFO – Received from (‘127.0.0.1’, 46076): Command: stop
\n2025-08-01 11:31:34,720 – serverInfo – INFO – Board 0 closed.
\n2025-08-01 11:31:45,608 – serverInfo – INFO – Received from (‘127.0.0.1’, 46076): Command: exit
\n2025-08-01 11:31:45,608 – serverInfo – INFO – Connection with (‘127.0.0.1’, 46076) closed.
\n2025-08-01 11:31:45,698 – serverInfo – INFO – Received from (‘127.0.0.1’, 46075): Command: exit
\n2025-08-01 11:31:45,698 – serverInfo – INFO – Connection with (‘127.0.0.1’, 46075) closed.<\/p>\nThe Web Application<\/strong><\/h4>\n
![\"\"](\"https:\/\/digilent.com\/blog\/wp-content\/uploads\/2025\/07\/MyVideo-1.gif\")
<\/p>\ndef create_board_selector():\r\n\r\n board_selection_options = []\r\n if daq_socket_manager.connect(HOST, PORT) is True:\r\n\r\n dev_list = daq_socket_manager.get_device_list()\r\n\r\n if len(dev_list) > 0:\r\n for device in dev_list:\r\n board = namedtuple('board', ['board_num',\r\n 'serial_num',\r\n 'type',\r\n 'product_name'])\r\n\r\n bd = board(board_num=device['Board_Number'],\r\n serial_num=device['Serial_Number'],\r\n type=device['Product_ID'],\r\n product_name=device['Name'])\r\n\r\n label = '{0}: {1}'.format(bd.board_num, bd.product_name)\r\n option = {'label': label, 'value': json.dumps(bd._asdict())}\r\n board_selection_options.append(option)\r\n\r\n selection = None\r\n if board_selection_options:\r\n selection = board_selection_options[0]['value']\r\n\r\n return dcc.Dropdown(\r\n id='daqSelector', options=board_selection_options,\r\n value=selection, clearable=False, style={'width': 200,\r\n 'height': 40,\r\n 'border-radius': '10px',\r\n 'font-size': '16px'})\r\n else:\r\n\r\n label = '{0}: {1}'.format(-1, 'no devices')\r\n option = {'label': label, 'value': 0}\r\n board_selection_options.append(option)\r\n return dcc.Dropdown(\r\n id='daqSelector', options=board_selection_options,\r\n clearable=False)\r\n<\/code><\/pre>\n<\/div>\nsize_of_double = ctypes.sizeof(ctypes.c_double)\r\n\r\nwhile self.stop_event.is_set():\r\n\r\n # get number of samples to receive\r\n samples_to_read = self.get_msg('int')\r\n chunk_size = size_of_double * samples_to_read\r\n\r\n # read the samples\r\n recv_str = b\"\"\r\n while len(recv_str) < chunk_size:\r\n diff = min(chunk_size - len(recv_str), chunk_size)\r\n chunk = self.socket.recv(diff)\r\n recv_str += chunk\r\n\r\n l = (len(recv_str) \/\/ struct.calcsize('d'))\r\n unpacked_tuple = struct.unpack('<' + 'd' * l, recv_str)\r\n\r\n self.data_list = list(unpacked_tuple)\r\n self.new_data = True\r\n\r\n<\/code><\/pre>\n<\/div>\n\n
