andes.io.streaming.Streaming#
- class andes.io.streaming.Streaming(system)[source]#
ANDES data streaming class to interface with CURENT LTB.
Methods
Build Varheader, Idxvgs and SysParam after power flow routine
connect
()Connect to DiME 2 server.
finalize
()Send
DONE
signal when simulation completeshandle_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 until the queue is empty.
Stream the results from the last step to modules
Broadcast all PMU measurements and BusFreq measurements in the variable pmudata