jaydee/auto_import
1
0
Fork 0
mirror of https://gitlab.sectorq.eu/jaydee/auto_import.git synced 2025-12-14 10:34:53 +01:00
Code Issues Packages Projects Releases Wiki Activity

build

Browse Source
This commit is contained in:
Ladislav Dusa
2025-06-29 13:27:17 +02:00
parent e694af2723
commit 1a4608c32e
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
auto_import_v2.py
View File

@@ -40,7 +40,7 @@ class mqtt_sender():
mqtt_s = mqtt_sender("mqtt.home.lan", 1883, "jaydee", "jaydee1") mqtt_s = mqtt_sender("mqtt.home.lan", 1883, "jaydee", "jaydee1")
mqtt_s.send_mqtt_message("sectorq/auto_import/job", {"status": "started","file":""}) mqtt_s.send_mqtt_message("sectorq/auto_import/job", {"status": "started","file":"","device":""})
@@ -196,7 +196,7 @@ for d in import_drives:
cmnd = "mkdir -p {}".format(_FDEST) cmnd = "mkdir -p {}".format(_FDEST)
status, output = subprocess.getstatusoutput(cmnd) status, output = subprocess.getstatusoutput(cmnd)
logging.debug("Moving file {} into {}".format(filename, _FDEST)) logging.debug("Moving file {} into {}".format(filename, _FDEST))
mqtt_s.send_mqtt_message("sectorq/auto_import/job", {"status": "started","file":filename}) mqtt_s.send_mqtt_message("sectorq/auto_import/job", {"status": "started","file":filename,"device":_DEV})
try: try:
shutil.move("{}/{}".format(FULL_PATH,filename),_FDEST) shutil.move("{}/{}".format(FULL_PATH,filename),_FDEST)
@@ -214,7 +214,7 @@ for d in import_drives:
subprocess.getstatusoutput(myCmd) subprocess.getstatusoutput(myCmd)
else: else:
logging.debug(f"File: {file_or_dir}") logging.debug(f"File: {file_or_dir}")
mqtt_s.send_mqtt_message("sectorq/auto_import/job", {"status": "started","file":file_or_dir}) mqtt_s.send_mqtt_message("sectorq/auto_import/job", {"status": "started","file":file_or_dir,"device":_DEV})
try: try:
shutil.move("{}/{}".format(_DEV_DIR,file_or_dir),_FDEST) shutil.move("{}/{}".format(_DEV_DIR,file_or_dir),_FDEST)
@@ -225,7 +225,7 @@ for d in import_drives:
logging.debug("failed to move file {}".format(file_or_dir)) logging.debug("failed to move file {}".format(file_or_dir))
else: else:
logging.debug("Nothing to import") logging.debug("Nothing to import")
mqtt_s.send_mqtt_message("sectorq/auto_import/job", {"status": "finished","file":f"{files_imported}"}) mqtt_s.send_mqtt_message("sectorq/auto_import/job", {"status": "finished","file":f"{files_imported}","device":_DEV})
else: else:
logging.debug("Unknown device") logging.debug("Unknown device")