AI N samples once

  1'''
  2AI - AI_N_samples_once.py with asynchronous mode.
  3
  4This example demonstrates the process of obtaining AI data in N-sample mode.
  5Additionally, it gets AI data with points in once from USBDAQF1AD.
  6
  7To begin with, it demonstrates the steps to open the AI and configure the AI parameters.
  8Next, it outlines the procedure for reading the streaming AI data.
  9Finally, it concludes by explaining how to close the AI.
 10
 11-------------------------------------------------------------------------------------
 12Please change correct serial number or IP and port number BEFORE you run example code.
 13
 14For other examples please check:
 15    https://github.com/WPC-Systems-Ltd/WPC_Python_driver_release/tree/main/examples
 16See README.md file to get detailed usage of this example.
 17
 18Copyright (c) 2022-2025 WPC Systems Ltd. All rights reserved.
 19'''
 20
 21## WPC
 22from wpcsys import pywpc
 23
 24## Python
 25import asyncio
 26import sys
 27sys.path.insert(0, 'src/')
 28
 29
 30async def main():
 31    ## Get Python driver version
 32    print(f'{pywpc.PKG_FULL_NAME} - Version {pywpc.__version__}')
 33
 34    ## Create device handle
 35    dev = pywpc.USBDAQF1AD()
 36
 37    ## Connect to device
 38    try:
 39        dev.connect("default")  ## Depend on your device
 40    except Exception as err:
 41        pywpc.printGenericError(err)
 42        ## Release device handle
 43        dev.close()
 44        return
 45
 46    try:
 47        ## Parameters setting
 48        port = 0  ## Depend on your device
 49        mode = 1  ## 0: On demand, 1: N-samples, 2: Continuous
 50        channel = 8
 51        sampling_rate = 1000
 52        samples = 200
 53        read_points = 200
 54        read_delay = 0.5  ## [sec]
 55
 56        ## Get firmware model & version
 57        driver_info = await dev.Sys_getDriverInfo_async()
 58        print(f"Model name: {driver_info[0]}, Firmware version: {driver_info[-1]} ")
 59
 60        ## Open AI
 61        err = await dev.AI_open_async(port)
 62        print(f"AI_open_async in port {port}, status: {err}")
 63        
 64        ## Set AI channel
 65        err = await dev.AI_enableChannel_async(port, channel)
 66        print(f"AI_enableChannel_async in port {port}, status: {err}")
 67        ## Set AI acquisition mode to N-samples mode (1)
 68        err = await dev.AI_setMode_async(port, mode)
 69        print(f"AI_setMode_async {mode} in port {port}, status: {err}")
 70
 71        ## Set AI sampling rate
 72        err = await dev.AI_setSamplingRate_async(port, sampling_rate)
 73        print(f"AI_setSamplingRate_async {sampling_rate} in port {port}, status: {err}")
 74
 75        ## Set AI # of samples
 76        err = await dev.AI_setNumSamples_async(port, samples)
 77        print(f"AI_setNumSamples_async {samples} in port {port}, status: {err}")
 78
 79        ## Open AI streaming
 80        err = await dev.AI_openStreaming_async(port)
 81        print(f"AI_openStreaming_async in port {port}, status: {err}")
 82
 83        ## Start AI streaming
 84        err = await dev.AI_startStreaming_async(port)
 85        print(f"AI_startStreaming_async in port {port}, status: {err}")
 86
 87        ## Read AI
 88        ai_2Dlist = await dev.AI_readStreaming_async(port, read_points, read_delay)
 89        print(f"number of samples = {len(ai_2Dlist)}")
 90
 91        ok = True
 92        for i, ai_list in enumerate(ai_2Dlist):
 93            ## Check for any missing data
 94            if len(ai_list) != channel:
 95                print(i, ai_list)
 96                ok = False
 97        if ok:
 98            print('OK')
 99        else:
100            print('NG')
101
102        ## Close AI streaming
103        err = await dev.AI_closeStreaming_async(port)
104        print(f"AI_closeStreaming_async in port {port}, status: {err}")
105
106        ## Close AI
107        err = await dev.AI_close_async(port)
108        print(f"AI_close_async in port {port}, status: {err}")
109    except Exception as err:
110        pywpc.printGenericError(err)
111
112    finally:
113        ## Disconnect device
114        dev.disconnect()
115
116        ## Release device handle
117        dev.close()
118
119
120def main_for_spyder(*args):
121    if asyncio.get_event_loop().is_running():
122        return asyncio.create_task(main(*args)).result()
123    else:
124        return asyncio.run(main(*args))
125
126
127if __name__ == '__main__':
128    asyncio.run(main())  ## Use terminal
129    # await main()  ## Use Jupyter or IPython(>=7.0)
130    # main_for_spyder()  ## Use Spyder