如何为AWS SFTP文件创建事件配置Argo EventSource？

AWS Transfer Family（即AWS SFTP服务）原生支持将文件操作事件推送到Amazon EventBridge，搭配Argo Events原生支持的EventBridge EventSource即可完成链路搭建，完整流程如下：

• 第一步：开启AWS SFTP的EventBridge事件推送
  进入AWS Transfer Family控制台，打开对应SFTP服务器的属性页，找到事件通知配置项，开启发送到Amazon EventBridge开关，选择触发事件为文件上传完成（UploadComplete）。
• 第二步：创建Argo Events EventBridge EventSource
  编写如下EventSource资源配置，注意替换占位参数为你实际的环境值：

  apiVersion: argoproj.io/v1alpha1
  kind: EventSource
  metadata:
    name: aws-sftp-event-source
  spec:
    eventBridge:
      sftp-file-upload:
        region: <你的AWS区域，例如us-east-1>
        eventBusName: default
        rule: |
          {
            "source": ["aws.transfer"],
            "detail-type": ["Transfer Family File Upload Complete"],
            "detail": {
              "serverId": ["<你的SFTP服务器ID>"]
            }
          }
        authentication:
          roleARN: <有权限消费EventBridge事件的IAM角色ARN>
  

  执行kubectl apply -f <上述配置文件名>完成部署。
• 第三步：配置Sensor匹配事件
  正常配置Argo Sensor监听上述EventSource产生的事件，提取事件中的文件路径、文件名等参数透传给Argo Workflow作为入参即可。

如果你的环境无法对接AWS原生EventBridge，可以基于Argo Events的Webhook EventSource+自定义轮询脚本实现：

• 第一步：部署Argo Events Webhook EventSource
  创建一个类型为Webhook的EventSource，对外暴露一个事件接收接口。
• 第二步：编写轻量轮询脚本
  脚本逻辑为：按你业务接受的延迟间隔（比如1分钟）扫描AWS SFTP指定目录的文件列表，和上一次扫描的结果做对比，发现新增文件后，将文件信息封装为POST请求发送到上述Webhook EventSource的接口。
• 第三步：部署轮询脚本
  可以将脚本打包为镜像在K8s集群中作为Deployment长期运行，也可以用CronJob定时触发运行，自行控制扫描频率即可。

注意：方案2的轮询延迟取决于你设置的扫描间隔，且需要自行处理重复文件检测、SFTP连接异常重试等边界问题，适合非核心、低频次的文件上传场景。

内容的提问来源于stack exchange，提问作者Aman