本文介绍通过应用集成实现从邮件服务器获取内容并发布到Kafka指定主题。完成从示例用户邮箱的收件箱里获取未读邮件,然后将获取到的内容发布到Kafka指定主题。

前提条件

背景信息

通过创建的集成,将完成以下动作:
  1. 从用户收件箱里读取邮件信息。
  2. 将获取到的邮件信息发布到Kafka的指定主题,本场景以发布到主题Topic1为例。

创建连接

本示例中会用到Email和Kafka服务,所以需要借助连接器创建对应的连接。

创建空白集成

  1. 登录应用集成控制台
  2. 在顶部菜单栏选择地域
  3. 在左侧导航栏选择集成 > 集成列表
  4. 集成列表页面单击新建集成
  5. 新建集成面板中创建方式选择为空白流,选择目标环境,输入名称,然后单击创建
  6. 集成创建后,返回集成设计页面,选择接下来的操作。
    • 在页面左上角选择工作空间,然后在右上角单击保存,创建一个空集成。
    • 在页面左上角单击 ,在列表中单击Flow,创建集成流。详情请参见创建空白集成

创建集成流

  1. 集成设计页面设置集成名,选择目标工作空间环境
  2. 集成设计页面左上角单击 ,在列表中单击Flow,创建集成流。
    也可以在页面中单击点击创建,在列表中单击Flow,创建集成流。
  3. 选择触发器,实现从用户邮件指定目录读取邮件信息。
    1. 创建新集成流对话框输入集成流名称,并选择之前创建的Email连接,然后单击创建
      创建集成流-email触发器
    2. 选择操作对话框Receive Email右侧,单击选择
      选择operation-Receive Email
    3. 步骤配置对话框设置邮件信息读取参数,然后单击确定
      步骤配置-指定文件夹
      步骤配置参数说明如下:
      参数 描述
      延迟 轮询读取邮件信息的时间间隔,默认值5000,单位ms。
      文件夹 邮件轮询文件夹,置空表示轮询收件箱。
      最大电子邮件数 返回邮件的最大数量(使用-1获取所有邮件),默认值5。
      是否只未读 是否值读取未读邮件。
    创建完成后,集成流即包含了从Email收件箱读取邮件信息的触发器。触发器-从Email读取邮件
  4. 在集成流中添加Kafka连接,将读取到的邮件发布到Kafka指定主题。
    1. 在集成流中Receive Email后单击
    1. 选择组件类型对话框单击连接,然后单击之前新建的Kafka连接。
    2. 选择操作对话框Publish右侧,单击选择
      选择operation-Publish
    3. 步骤配置对话框主题名列表中选择目标主题,然后单击确定
      步骤配置-指定主题
    4. 设置inputDataShape对话框选择scheme列表中选择任意类型,然后单击创建
  5. 集成设计页面右上角单击保存,保存集成流。
    读取收件箱的邮件信息并发布到Kafka指定主题的集成流创建完成。邮件发布到Kafka指定主题
    说明 返回集成设计页面时,请及时在页面右上角单击保存,以免添加的步骤丢失。

部署集成

集成创建并保存后,需要对集成进行部署。详情请参见部署集成示例

结果验证

  • 验证Kafka的消息代理。
    • 登录Kafka服务器,查看主题Topic1是否含有邮件信息。
    • 您也可以重新发送一封邮件到示例用户邮箱,然后在Kafka的主题Topic1中查看是否含有新发的邮件。
  • 验证集成部署是否正常运行。

    查看目标集成的执行记录,其执行日志状态是否为SUCCESS