【发布时间】:2022-01-19 17:41:53
【问题描述】:
我正在尝试通过 Airflow 自动从 SFTP 服务器传输文件,但我遇到了一个问题,我无法将文件保存到根文件夹以外的任何地方。
这是我的代码的 sn-p:
cnopts = pysftp.CnOpts()
cnopts.hostkeys = None
with pysftp.Connection(host=myHostname, username=myUsername, password=myPassword, private_key=".ppk",
cnopts=cnopts) as sftp:
print("Connection succesfully stablished ... ")
# Obtain structure of the remote directory '/var/www/vhosts'
directory_structure = sftp.listdir_attr()
#Download data
for attr in directory_structure:
if datetime.fromtimestamp(attr.st_mtime) >= datetime.strptime("2022-01-18", "%Y-%m-%d"):
sftp.put(attr.filename,"/volume1/homes/[myuser]/Recordings/{a}".format(a=attr.filename))
当我运行这个 DAG 时,我收到以下错误
FileNotFoundError: [Errno 2] 没有这样的文件或目录:
任何有关如何解决此问题的建议将不胜感激。
【问题讨论】:
标签: python airflow sftp paramiko pysftp