Merge pull request #191 from nttcom/log_send_check

#138 ログ化機能・ログ送信機能の分離、及びNWアクセス制御

Author: takuma0121

osect_sensor/Application/edge_cron/common/common_config.py

@@ -86,3 +86,6 @@
 
 SEND_REQUST_TIMEOUT = 180
 """ ログ送信時のタイムアウト値 """
+
+IS_CLOSED_NETWORK = True
+""" モバイル経由のフラグ """

osect_sensor/Application/edge_cron/cron/management/commands/pcap_to_log_to_server.py

@@ -16,6 +16,7 @@
 
 import requests
 import zstandard as zstd
+import serial
 from common.common_config import (
     ALLOWED_LOG_EXT,  # BACNET_SHELL_COMMAND,
     ALLOWED_PCAP_EXT,
@@ -46,6 +47,7 @@
     API_URL,
     LABEL_ID,
     CLIENT_CERTIFICATE_PATH,
+    IS_CLOSED_NETWORK,
 )
 
 # from common.common_function import pcap2log
@@ -146,7 +148,23 @@ def handle(self, *args, **options):
         # logger.info("sleep " + str(sleep_time) + "s")
 
         try:
-            send_server(tar_list)
+            if IS_CLOSED_NETWORK:
+                # コア網チェック
+                with serial.Serial("/dev/ttyUSB1", baudrate=115200, timeout=1) as sara:
+                    sara.write(b"at\r\n")
+                    b = sara.read(16)
+                    cnum = b.decode().split("\n")
+
+                if "OK\r" in cnum:
+                    # ログ送信
+                    send_server(tar_list)
+                else:
+                    logger.error(
+                        "can not send compressed file. Unable to connect to closed network. "
+                    )
+            else:
+                # ログ送信
+                send_server(tar_list)
         except Exception as e:
             logger.error("can not send compressed file. " + str(e))
 

osect_sensor/Infrastructure/edge_cron/work/requirements.txt

@@ -4,3 +4,4 @@ meson==0.56.0
 requests==2.31.0
 urllib3==1.26.6
 zstandard==0.18.0
+pyserial==3.4

osect_sensor/README.md

@@ -201,6 +201,41 @@ NTT Comから提供されたクライアント証明書を以下に格納しま
 $ ~/osect_sensor/keys/client.pem
 ```
 
+### 3.5. ログ送信方式の設定
+
+有線経由でログを送信する場合は以下の設定をします。
+
+設定ファイル:
+
+```bash
+$ vi Application/edge_cron/common/common_config.py
+```
+
+変更箇所:
+
+```python
+# 無線経由で送信
+IS_CLOSED_NETWORK = True
+↓
+# 有線経由で送信
+IS_CLOSED_NETWORK = False
+```
+
+設定ファイル:
+
+```bash
+$ vi docker-compose.yml
+```
+
+変更箇所:
+
+```yml
+    devices:
+      - "/dev/ttyUSB1:/dev/ttyUSB1"
+↓
+（削除）
+```
+
 ## 4. コンテナの構築・起動
 
 コンテナを構築、起動します。

osect_sensor/docker-compose.yml

@@ -3,6 +3,8 @@ services:
   edge_cron:
     image: cron:revxxx
     build: "./Infrastructure/edge_cron/"
+    devices:
+      - "/dev/ttyUSB1:/dev/ttyUSB1"
     volumes:
       - ./Application/edge_cron:/opt/edge_cron
       - pcap-logs-volume:/opt/edge_cron/paper/sc_src/input/pcap/complete/