minor clean-up dnp3 agent rpc.export

src/dnp3demo/multi_stations_demo.py

@@ -0,0 +1,155 @@
+import logging
+import random
+import sys
+
+from pydnp3 import opendnp3
+
+from dnp3_python.dnp3station.master_new import MyMasterNew
+from dnp3_python.dnp3station.outstation_new import MyOutStationNew
+
+import datetime
+from time import sleep
+
+stdout_stream = logging.StreamHandler(sys.stdout)
+stdout_stream.setFormatter(logging.Formatter('%(asctime)s\t%(name)s\t%(levelname)s\t%(message)s'))
+
+_log = logging.getLogger(__name__)
+# _log = logging.getLogger("data_retrieval_demo")
+_log.addHandler(stdout_stream)
+_log.setLevel(logging.DEBUG)
+
+
+def main():
+
+    outstation_application = MyOutStationNew()
+    outstation_application.start()
+    _log.debug('Initialization complete. OutStation in command loop.')
+
+    master_application = MyMasterNew()
+    master_application.start()
+    _log.debug('Initialization complete. Master Station in command loop.')
+
+    outstation_application_20001 = MyOutStationNew(port=20001)
+    outstation_application_20001.start()
+    _log.debug('Initialization complete. OutStation p20001 in command loop.')
+
+    master_application_20001 = MyMasterNew(port=20001)
+    master_application_20001.start()
+    _log.debug('Initialization complete. Master p20001 Station in command loop.')
+
+    count = 0
+    while count < 10:
+        sleep(1)  # Note: hard-coded, master station query every 1 sec.
+
+        count += 1
+        print(datetime.datetime.now(), "============count ", count, )
+
+        # plan: there are 3 AnalogInput Points,
+        # outstation will randomly pick from
+        # index 0: [4.0, 7.0, 2.0]
+        # index 1: [14.0, 17.0, 12.0]
+        # index 1: [24.0, 27.0, 22.0]
+
+        # outstation update point value (slower than master station query)
+        if count % 3 == 1:
+            point_values_0 = [4.8, 7.8, 2.8]
+            point_values_1 = [14.1, 17.1, 12.1]
+            point_values_2 = [24.2, 27.2, 22.2]
+            point_values_0 = [val + random.random() for val in point_values_0]
+            point_values_1 = [val + random.random() for val in point_values_1]
+            point_values_2 = [val + random.random() for val in point_values_2]
+            for i, pts in enumerate([point_values_0, point_values_1, point_values_2]):
+                p_val = random.choice(pts)
+                print(f"====== Outstation update index {i} with {p_val}")
+                outstation_application.apply_update(opendnp3.Analog(value=float(p_val),
+                                                                    flags=opendnp3.Flags(24),
+                                                                    time=opendnp3.DNPTime(3094)), i)
+                # outstation_application.apply_update(opendnp3.AnalogIn(value=float(p_val),
+                #                                                     flags=opendnp3.Flags(24),
+                #                                                     time=opendnp3.DNPTime(3094)), i)
+
+        # update binaryInput value as well
+        if count % 3 == 1:
+            point_values_0 = [True, False]
+            point_values_1 = [True, False]
+            point_values_2 = [True, False]
+            for i, pts in enumerate([point_values_0, point_values_1, point_values_2]):
+                p_val = random.choice(pts)
+                print(f"====== Outstation update index {i} with {p_val}")
+                outstation_application.apply_update(opendnp3.Binary(True), i)
+
+        if count == 4:
+            master_application_20001.shutdown()
+            print(MyOutStationNew.outstation_application_pool)
+
+        # master station retrieve outstation point values
+
+        # # use case 1: retrieve float analogInput values specified by GroupVariationID(30, 6)
+        # result = master_application.retrieve_all_obj_by_gvid(gv_id=opendnp3.GroupVariationID(30, 6),
+        #                                                      config=opendnp3.TaskConfig().Default())
+        # print(f"===important log: case1 retrieve_all_obj_by_gvid GroupVariationID(30, 6)==== {count}",
+        #       result)
+        #
+        # # use case 2: retrieve binaryInput values specified by GroupVariationID(1, 2)
+        # result = master_application.retrieve_all_obj_by_gvid(gv_id=opendnp3.GroupVariationID(1, 2),
+        #                                                      config=opendnp3.TaskConfig().Default())
+        # print(f"===important log: case2 retrieve_all_obj_by_gvid GroupVariationID(1, 2) ==== {count}",
+        #       result)
+        #
+        # # # use case 3: retrieve point values specified by a list of GroupVariationIDs.
+        # # # by default, retrieve float AnalogInput, BinaryInput, float AnalogOutput, BinaryOutput
+        # # result = master_application.retrieve_all_obj_by_gvids()
+        # # print(f"===important log: case3 retrieve_all_obj_by_gvids default ==== {count}",
+        # #       result)
+        #
+        # # use case 4: retrieve point values specified by a list of GroupVariationIDs.
+        # # demo float AnalogInput, BinaryInput,
+        # result = master_application.retrieve_all_obj_by_gvids(gv_ids=[opendnp3.GroupVariationID(30, 6),
+        #                                                               opendnp3.GroupVariationID(1, 2)])
+        # print(f"===important log: case4 retrieve_all_obj_by_gvids default ==== {count}", datetime.datetime.now(),
+        #       result)
+        #
+        # use case 5: (for debugging purposes) retrieve point values specified by a list of GroupVariationIDs.
+        # demo float AnalogInput, BinaryInput,
+        result = master_application._retrieve_all_obj_by_gvids_w_ts(gv_ids=[opendnp3.GroupVariationID(30, 6),
+                                                                      opendnp3.GroupVariationID(1, 2)])
+        # print(f"===important log: case5 _retrieve_all_obj_by_gvids_w_ts default ==== {count}", datetime.datetime.now(),
+        #       result)
+        #
+        # # use case 6: retrieve point values specified by single GroupVariationIDs and index.
+        # # demo float AnalogInput,
+        # # result = master_application.retrieve_all_obj_by_gvids(gv_ids=[opendnp3.GroupVariationID(30, 6),
+        # #                                                               opendnp3.GroupVariationID(1, 2)])
+        # # result = master_application.retrieve_val_by_gv(gv_id=opendnp3.GroupVariationID(30, 6),)
+        # result = master_application.get_db_by_group_variation(group=30, variation=6)
+        # print(f"===important log: case6 get_db_by_group_variation ==== {count}", datetime.datetime.now(),
+        #       result)
+        # result = master_application.get_db_by_group_variation(group=1, variation=2)
+        # print(f"===important log: case6b get_db_by_group_variation ==== {count}", datetime.datetime.now(),
+        #       result)
+        # result = master_application.get_db_by_group_variation(group=30, variation=1)
+        # print(f"===important log: case6c get_db_by_group_variation ==== {count}", datetime.datetime.now(),
+        #       result)
+        #
+        # # use case 7: retrieve point values specified by single GroupVariationIDs and index.
+        # # demo float AnalogInput,
+        # # result = master_application.retrieve_all_obj_by_gvids(gv_ids=[opendnp3.GroupVariationID(30, 6),
+        # #                                                               opendnp3.GroupVariationID(1, 2)])
+        # # result = master_application.retrieve_val_by_gv_i(gv_id=opendnp3.GroupVariationID(30, 6), index=0)
+        # result = master_application.get_db_by_group_variation_index(group=30, variation=6, index=0)
+        # print(f"===important log: case7 get_db_by_group_variation_index ==== {count}", datetime.datetime.now(),
+        #       result)
+        # result = master_application.get_val_by_group_variation_index(group=30, variation=6, index=1)
+        # print(f"===important log: case7b get_db_by_group_variation_index ==== {count}", datetime.datetime.now(),
+        #       result)
+        # result = master_application.get_val_by_group_variation_index(group=40, variation=4, index=0)
+        # print(f"===important log: case7c get_db_by_group_variation_index ==== {count}", datetime.datetime.now(),
+        #       result)
+
+    _log.debug('Exiting.')
+    master_application.shutdown()
+    outstation_application.shutdown()
+
+
+if __name__ == '__main__':
+    main()