FTP 数据源

source = FtpSource(
    host='ftp.example.com',
    port=21,
    username='your-username',
    password='your-password'
)

from xparse_client import FtpSource, Pipeline

source = FtpSource(
    host='ftp.example.com',
    port=21,
    username='myuser',
    password='mypassword'
)

# ... 其他配置

pipeline = Pipeline(
    source=source,
    # ...其他配置
)
pipeline.run()