andes.io.streaming.Streaming#

class andes.io.streaming.Streaming(system)[source]#

ANDES data streaming class to interface with CURENT LTB.

__init__(system)[source]#

Methods

build_init()

Build Varheader, Idxvgs and SysParam after power flow routine

connect()

Connect to DiME 2 server.

finalize()

Send DONE signal when simulation completes

handle_alter(Alter)

Handle parameter altering

handle_event(Event)

Handle Fault, Breaker, Syn and Load Events

record_module_init(name, init_var)

Record the variable requests from modules

send_init([recepient])

Broadcast Varheader, Idxvgs and SysParam to all DiME clients after power flow routine

sync_and_handle()

Sync until the queue is empty.

transpose_matlab_row(a)

vars_to_modules()

Stream the results from the last step to modules

vars_to_pmu()

Broadcast all PMU measurements and BusFreq measurements in the variable pmudata