class SFTPOperation(object):
PUT = 'put'
GET = 'get'
operation=SFTPOperation.GET,
NameError: name 'SFTPOperation' is not defined
我在这里定义了运营商,但在互联网上找不到任何与运营相关的内容
class sftpplugin(AirflowPlugin):
name = "sftp_plugin"
operators = [SFTPOperator]
任何帮助都将不胜感激
谢谢
Tags:
注意到SFTP操作符使用ssh_钩子打开sftp传输通道,您应该需要为文件传输提供
ssh_hook
或ssh_conn_id
。首先,让我们看一个提供参数ssh_conn_id
的示例请注意,dag应该根据任务的需要进行调度,这里的示例考虑从中午开始的每日调度。现在,如果您正在提供SSHhook,则需要对上述代码进行以下更改
其中
"Name_of_variable_defined"
是在Admin->;气流接口处的连接相关问题 更多 >
编程相关推荐