diff --git a/auto_import_v2_auto.py b/auto_import_v2_auto.py index d963950..6fc07ad 100644 --- a/auto_import_v2_auto.py +++ b/auto_import_v2_auto.py @@ -177,12 +177,21 @@ while True: mqtt_s.send_mqtt_message("sectorq/auto_import/job", {"status": "started","file":filename,"device":_DEV}) try: shutil.copy("{}/{}".format(FULL_PATH,filename),_FDEST) + myCmd = f"rsync -avz {FULL_PATH}/{filename} {_FDEST}" + status, output = subprocess.getstatusoutput(myCmd) + + + files_imported += 1 except: try: - shutil.copy("{}/{}".format(FULL_PATH,filename),"{}/{}".format(_FDEST,filename)) + #shutil.copy("{}/{}".format(FULL_PATH,filename),"{}/{}".format(_FDEST,filename)) + myCmd = f"rsync -avz {FULL_PATH}/{filename} {_FDEST}" + status, output = subprocess.getstatusoutput(myCmd) + logging.debug(output) + logging.debug(status) files_imported += 1 except: logging.debug("failed to move file {}".format(filename)) @@ -194,11 +203,17 @@ while True: mqtt_s.send_mqtt_message("sectorq/auto_import/job", {"status": "started","file":file_or_dir,"device":_DEV}) try: shutil.copy("{}/{}".format(_DEV_DIR,file_or_dir),_FDEST) + myCmd = f"rsync -avz {_DEV_DIR}/{file_or_dir} {_FDEST}" + status, output = subprocess.getstatusoutput(myCmd) files_imported += 1 except: try: shutil.copy("{}/{}".format(_DEV_DIR,file_or_dir),"{}/{}".format(_FDEST,file_or_dir)) + myCmd = f"rsync -avz {_DEV_DIR}/{file_or_dir} {_FDEST}" + status, output = subprocess.getstatusoutput(myCmd) + + files_imported += 1 except: logging.debug("failed to move file {}".format(file_or_dir))