Example Python script to implement the Phasemeter (streaming).

# pymoku example: Phasemeter networking streaming
#
# This example starts a 10-second network stream of Channel 1 Phasemeter data
# and processes it live. The contents of each data sample are printed out,
# along with the signal amplitude which may be calculated as A = (I^2 + Q^2).
# 
# (c) 2019 Liquid Instruments Pty. Ltd.
#

from pymoku import Moku, StreamException, FrameTimeout
from pymoku.instruments import Phasemeter
import math

# Connect to your Moku by its device name
# Alternatively, use Moku.get_by_serial('#####') or Moku('192.168.###.###')
m = Moku.get_by_name('Moku')

try:
 i = m.deploy_or_connect(Phasemeter)

 # Set the measurement rate to ~120Hz
 i.set_samplerate('fast')

 # Automatically acquire a PLL seed frequency for both channels
 i.auto_acquire()

 # Stop previous network session, if any
 i.stop_stream_data()

 # Start a new Phasemeter network stream
 # Channel 1 enabled, Duration 10 seconds
 i.start_stream_data(duration=10, ch1=True, ch2=False)

 # This loop continuously retrieves Phasemeter Channel 1 data samples off
 # the network and prints out their contents. It breaks out of the loop when
 # there are no samples received, indicating the end of the streaming
 # session.
 while True:
 # Get 10 samples off the network at a time
 samples = i.get_stream_data(n=10)

 # No samples indicates end of stream
 if not any(samples):
 break

 # Process the received samples
 # Here we just print the contents of Channel 1 samples
 # Along with signal amplitude (I^2 + Q^2)
 ch1_samples = samples[0]
 for s in ch1_samples:
 # s is of the form [fs, f, count, phase, I, Q]
 print("Ch1 - fs: %f, f: %f, phase: %f, amplitude: %f"
 % (s[0], s[1], s[3], math.sqrt(s[4]**2 + s[5]**2)))

 i.stop_stream_data()
except StreamException as e:
 print("Error occured: %s" % e)
except FrameTimeout:
 print("Logging session timed out")
finally:
 # Close the connection to the Moku:Lab
 m.close()