Initial draft of agentMET4FOF connector

run_agents.py

+import glob
+import os
+import numpy as np
+import pandas as pd
+
+# import directly from git folder
+import sys
+sys.path.append("../agentMET4FOF")
+from agentMET4FOF.agents import AgentMET4FOF, AgentNetwork, MonitorAgent
+from agentMET4FOF.streams import DataStreamMET4FOF
+
+
+class SensorAgent(AgentMET4FOF):
+
+    def init_parameters(self, sampling_period=1.0):
+        self.sampling_period = sampling_period
+
+    def on_received_message(self, message):
+        # do something
+        self.send_output(1.0)
+
+
+class SensorStream(DataStreamMET4FOF):
+
+    def __init__(self, sensor_id=""):
+        
+        x = np.random.random(300)
+        y = None
+
+        self.set_data_source(x,y)
+
+
+def main():
+    # start agent network server
+    agentNetwork = AgentNetwork([SensorAgent,SensorStream])
+
+    # init agents
+    monitor_agent = agentNetwork.add_agent(agentType=MonitorAgent)
+    sensor_agent = agentNetwork.add_agent(agentType=SensorAgent)
+    
+    # connect
+    agentNetwork.bind_agents(sensor_agent, monitor_agent)
+    
+    # set all agents states to "Running"
+    agentNetwork.set_running_state()
+
+    # allow for shutting down the network after execution
+    return agentNetwork
+
+
+if __name__ == '__main__':
+    main()
\ No newline at end of file