Welding/TraceDelivery
9
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: поправки для демонстрации

Browse Source
This commit is contained in:
Андрей Скирченко 2025-02-19 16:50:40 +03:00
parent d7f15f7b2f
commit 40ea273b09
3 changed files with 8 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
data/connection.json
View File

@ -1,6 +1,6 @@
{ {
"host": "172.21.5.240", "host": "172.21.5.229",
"port": 22, "port": 22,
"username": "smart", "username": "smart",
"password": "00000000" "password": "00000000"
} }

11
data/path.json
View File

@ -1,16 +1,9 @@
[ [
{ {
"source": "/home/smart/PN/TWC/trace/Weld Point", "source": "/home/smart/TWC/trace/Technological",
"buffer": "/home/andrei/PycharmProjects/traceDelivery/buffer", "buffer": "/home/andrei/PycharmProjects/traceDelivery/buffer",
"destination": "/home/andrei/Desktop/bla", "destination": "/home/andrei/Desktop/bla",
"apply_filter": true, "apply_filter": true,
"sigma_filter": 3 "sigma_filter": 3
},
{
"source": "/home/smart/PN/TWC/trace/test1",
"buffer": "/home/andrei/PycharmProjects/traceDelivery/buffer",
"destination": "/home/andrei/Desktop/bla",
"apply_filter": false,
"sigma_filter": 3
} }
] ]

5
src/main.py
View File

@ -1,6 +1,7 @@
import json import json
import os import os
from concurrent.futures import ThreadPoolExecutor from concurrent.futures import ThreadPoolExecutor
import threading
from remote.client import SSHClient from remote.client import SSHClient
from remote.connection_data import SSHConnectionParams from remote.connection_data import SSHConnectionParams
@ -34,7 +35,9 @@ def start_subscription(ssh_connection_object: SSHConnectionParams,
client.connect() client.connect()
subscriber = Subscriber(client.sftp, element) subscriber = Subscriber(client.sftp, element)
tuner.accept(subscriber) tuner.accept(subscriber)
executor.submit(subscriber.subscribe) t = threading.Thread(target=subscriber.subscribe(), args=())
t.start()
# executor.submit(subscriber.subscribe)
def main(): def main():