Apache SeaTunnel如何发起HTTP POST请求？求示例及语法

如果你需要在Apache SeaTunnel中配置HTTP POST请求作为数据源，可以通过指定请求方法、请求头和请求体来实现，以下是完整的配置示例：

env:
  execution.parallelism: 1
  job.mode: BATCH

source:
  Http:
    # 替换为你的POST接口地址
    url: "https://target-api.example.com/submit"
    # 指定请求方法为POST
    method: POST
    # 设置请求头，根据接口要求添加必要字段，比如Content-Type
    headers:
      Content-Type: "application/json"
      Authorization: "Bearer your-token"
    # 定义POST请求体内容，格式需与Content-Type匹配
    request_body: '{"param1": "value1", "param2": 123}'
    # 轮询请求的间隔时间（毫秒），按需调整
    poll_interval: 10000
    # 接口返回结果的数据类型，支持JSON/TEXT等
    result_type: JSON
    # 从返回结果中提取的字段名，根据实际返回结构调整
    field_names: ["response_data"]

关键配置项说明 #

• method: 必须设置为POST，明确指定HTTP请求方法
• request_body: 填写POST请求的请求体内容，注意格式要和headers中的Content-Type一致（比如JSON格式要保证语法正确）
• headers: 按需添加接口要求的请求头，比如认证信息、内容类型等
• poll_interval: 当以轮询方式请求接口时，设置两次请求的间隔时间，批量模式下可根据需求调整

如果需要动态生成请求体（比如包含变量或运行时参数），可以使用SeaTunnel的变量替换功能，例如：

request_body: '{"timestamp": "${now()}", "user_id": "${env(user_id)}"}'

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