本文介绍通过HTTP请求将HTTP端点内容发布到MQTT指定主题。完成访问HTTP端点URL，发送GET请求将获取的内容发布到MQTT的指定主题。

前提条件

在阿里云容器服务Kubernetes版上创建了MQTT服务。具体操作步骤，请参见使用镜像快速创建无状态Deployment应用。

背景信息

通过集成流配置可以调用HTTPS端口URL，实现将信息发布到MQTT服务器的指定主题。 调用HTTPS端口URL的方式支持GET、PUT、POST、DELETE、HEAD、OPTIONS、TRACE和PATCH。

本文创建的集成将实现以下功能：
  1. 访问HTTPS端口URL。
  2. 将信息发布到MQTT的主题中，本场景示列为发布到主题Topic1中。

创建连接

本示例中会用到MQTT和HTTPS，所以需要借助连接器创建对应的连接。

创建空白集成

  1. 登录应用集成控制台。
  2. 在顶部菜单栏，选择地域。
  3. 在左侧导航栏，选择集成 > 集成列表。
  4. 在集成列表页面，选择目标工作空间，然后单击新建集成。
  5. 在新建集成面板，选择创建方式为空白流，选择目标环境，输入集成名称，然后单击创建。
  6. 集成创建后，进入集成设计页面，在右上角单击保存。

创建集成流

  1. 在集成设计页面左上角单击 图标，在列表中单击Flow，创建集成流。
    也可以在页面中，选择点击创建 > Flow，创建集成流。
  2. 选择触发器，实现访问HTTPS端口URL。
    1. 在创建新集成流对话框，输入名称，并选择HTTPS连接作为触发器，然后单击创建。创建https触发器
    2. 在选择操作对话框，单击Periodic invoke URL右侧的选择。选择operation
    3. 在步骤配置对话框，设置参数，然后单击确定。步骤配置
      步骤配置参数说明：
      参数 描述
      URL路径 调用HTTPS端点URL的path路径，可根据实际情况设置。
      Http方法 调用方式，默认为GET。

      包含的调用方式有GET、PUT、POST、DELETE、HEAD、OPTIONS、TRACE和PATCH，请根据实际需要选择。
      周期 调用周期，默认为1800000，单位ms，可根据实际需要设置为其他周期。
    4. 在设置outputDataShape对话框，在选择schema列表中选择任意类型，然后单击创建。
    创建完成后，集成流中即包括定期访问HTTPS端点URL的触发器。触发器-https端点定期访问
  3. 在集成流中添加MQTT，实现将消息发布到MQTT指定主题。
    1. 在集成流中Periodic invoke URL后单击图标。
    2. 在选择组件类型对话框，单击连接，然后单击MQTT连接。
    3. 在选择操作对话框，单击Publish右侧的选择。
      选择operation-MQTT代理
    4. 在步骤配置对话框，设置信息发布到MQTT代理的指定主题的名称，然后单击确定。
      本场景示列为发布到主题Topic1中。步骤配置-指定队列或主题
    5. 在设置inputDataShape对话框，在选择schema列表中选择任意类型，然后单击创建。
  4. 在集成设计页面右上角，单击保存，保存集成流。
    HTTPS协议处理（MQTT）集成流创建完成。HTTPS协议处理（MQTT）-集成流创建完成
    注意 在集成设计页面时，请及时在页面右上角单击保存，以免添加的步骤丢失。

部署集成

集成创建并保存后，需要对集成进行部署。具体操作，请参见部署集成示例。

结果验证

  • 验证MQTT的消息代理。

    登录MQTT服务器，查看主题Topic1是否有从HTTPS端点发布的消息。

  • 验证集成部署是否正常运行。

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