Fuse 在线示例集成教程

Red Hat Fuse 7.11

探索如何使用 Fuse Online(基于 Web 的 Fuse 分发)来创建示例集成

Red Hat Fuse Documentation Team

摘要

按照创建 Fuse 在线示例集成的逐步说明。

前言

Fuse Online 可让您从应用程序或服务获取数据,如果需要,请在该数据上运行,然后将数据发送到完全不同的应用程序或服务。您可以在不编写代码的情况下执行此操作。

通过创建示例集成来探索 Fuse Online。比较表 可帮助您确定首先创建的示例集成。然后参阅创建示例集成的说明。

另外还提供了 Fuse Online 的 用户指南

要获得支持,请在 Fuse Online 的左侧导航面板中,点 Support,或者在右上角点 InfoIcon ,然后选择 Support

使开源包含更多

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。我们从这四个术语开始:master、slave、黑名单和白名单。由于此项工作十分艰巨,这些更改将在即将推出的几个发行版本中逐步实施。详情请查看我们的 CTO Chris Wright 信息

第 1 章 选择示例集成以首先创建

您可以以任何顺序创建示例集成。为了帮助您决定首先尝试什么,下表比较了它们。

 

Twitter 到 Salesforce

Salesforce 到数据库

AMQ 到 REST API

它做什么

捕获和过滤器调整提及特定 Twitter 用户。对于包含指定文本的调整内容,该集成会将与 十二相关的数据传递给 Salesforce,而是创建一个新的联系人。

在 Salesforce 中捕获更新,然后调用存储的数据库流程,以便将特定数据库表与 Salesforce 更新同步。

从 Red Hat AMQ 代理获取交付记录,执行自定义步骤来识别收到时损坏的任何项目,并连接到 REST API,以提供针对供应商损坏项目的联系信息。

您了解的内容

连接到 Twitter 和 Salesforce,Fuse Online 接口如何与使用 OAuth 协议的应用程序进行连接,将接收的数据字段映射到集成中下一个连接的应用程序可以操作的字段,过滤数据以确定是否继续集成执行。

作为集成的一部分,连接至 Salesforce 和 SQL 数据库、OAuth 支持、数据映射、如何更新 SQL 数据库。

使用自定义步骤和自定义 API 客户端连接,连接至 Red Hat AMQ 代理和 REST API 客户端映射,为步骤上传扩展以及 REST API 客户端连接器。

完成平均分钟

25

20

25

关于时间的备注

这包括获取 Twitter 和 Salesforce 帐户所需的时间。它不包括 5 到 12 分钟,等待 Salesforce 注册生效,Fuse Online 则开始运行集成。

20 分钟包括获取 Salesforce 开发人员帐户所需的时间,但不是等待的时间。如果您已将 Twitter 创建给 Salesforce 示例,那么创建此集成需要 10 分钟时间。

这不包括 Fuse Online 开始运行集成所需的时间。

先决条件

Twitter 开发人员帐户,Salesforce 开发人员帐户

Salesforce Developer 帐户,启用 todo addon 选项(用于示例 todo 应用程序和示例 Postgres 数据库)

启用 todo addon 选项(例如 todo application、example Postgres 数据库和 AMQ 代理)

第 2 章 向 Salesforce 示例集成实施 Twitter

此示例集成会监控 Twitter,其中提到了特定的 Twitter 用户。当集成发现此类调整时,它会过滤它们,以便只对包含您所指定的文本而进行相应的调整。

对于包含指定文本的调整内容,该集成会传递与调整内容相关的数据,包括 Twitter 用户名,向 Salesforce 和 Salesforce 创建一个新的联系人。

先决条件

  • 您需要一个 Twitter 开发人员帐户。如果还没有设置,请转到 https://apps.twitter.com,登录 Twitter,然后点击 Apply for developer 帐户。当您提供专业电子邮件地址(如 me@redhat.com )而不是个人地址(如 you@gmail.com )时,可以快速获取开发人员帐户。
  • 您需要一个用于开发环境的 Salesforce 安装中的帐户。此帐户必须具有 Salesforce API 访问权限,该帐户可在 Salesforce Enterprise 帐户或 Salesforce Developer 帐户中可用。要获得免费开发人员帐户,请访问 https://developer.salesforce.com/signup。获取 Salesforce 帐户需要不到两分钟。
  • 您必须登录 Fuse 在线环境。

要实现、部署和测试此示例集成,请运行以下主要步骤:

2.1. 将 Fuse Online 注册为 Twitter 客户端应用程序

在集成中,要连接到 Twitter,您必须先执行的第一个操作是将 Fuse 在线环境注册为可访问 Twitter 的客户端应用程序。这可让您创建连接到 Twitter 的任何数量集成。换句话说,您需要在 Twitter 中注册特定的 Fuse Online 环境。

在每个 Fuse 在线环境中,每个 Fuse 在线环境中只能将一个 Fuse Online 注册为 Twitter 客户端应用程序。但是,虽然每个 Twitter 连接都使用相同的注册,但它会使用不同的用户凭证。

前提条件

您已登录到 Fuse Online。

流程

  1. 在 Fuse Online 中:

    1. 在左侧面板中,单击 Settings
    2. Settings 页面中,在回调 URL 右侧,点 Copy Callback URL 将 Fuse Online 安装的回调 URL 复制到剪贴板。稍后您将需要这个 URL。
    3. 单击 Twitter 条目,以显示 Consumer API KeyConsumer API Secret Key 字段。
  2. 在另一个浏览器标签页中,转至您的 Twitter 开发人员帐户,如果需要,请执行以下操作:

    1. Projects & Apps
    2. Overview 页面中,向下滚动到 STand standalone Apps,然后单击 Create App
    3. App name 字段中输入一个名称,如 My Fuse Online Client
    4. 向下滚动到 Setup Your App,然后点 App settings
    5. 向下滚动到 用户身份验证设置, 单击 Set up
    6. OAuth 1.0a 选项上切换。
    7. 对于 App 权限,请选择 Read and write and Direct 消息
    8. Callback URL 字段中,粘贴您在此流程开始时复制的 URL。它应该类似: https://app-proj912876.7b63.fuse-ignite.openshiftapps.com/api/v1/credentials/callback
    9. Website URL 字段中,再次粘贴 URL,并从 URL 末尾删除 /api/v1/credentials/callback

      您可以跳过下一几个字段。

    10. 点击 Save
    11. 在您刚才创建的应用程序页面的顶部,点击 Keys 和 tokens 选项卡。
    12. Consumer Keys 下,点 Regenerate,然后验证您要重新生成它们。
    13. 复制 API 密钥。
  3. 返回到您的 Fuse Online Settings 页面,并将 Twitter consumer API 密钥粘贴到 Fuse Online Twitter Consumer API Key 字段中。
  4. 返回到 Twitter Keys 和 tokens 选项卡,再复制使用者 API secret 密钥。
  5. 返回到您的 Fuse Online Settings 页面,并将 Twitter 使用者 API secret 密钥粘贴到 Fuse Online Twitter Consumer API Secret Key 字段中。
  6. 点击 Save
  7. Twitter 条目折叠它。

2.2. 创建 Twitter 连接

要创建从 Twitter 获取数据的集成,您必须首先创建一个 Twitter 连接。创建 Twitter 连接后,您可以在任意数量集成中使用它。

先决条件

  • 您已登录到 Fuse Online。
  • Fuse Online 在网页浏览器中打开。
  • 将 Fuse Online 环境注册为可访问 Twitter 的应用程序。
  • 您会将您在注册后收到的 Twitter 使用者 API 密钥和消费者 API secret 密钥添加到 Fuse Online Settings 页面。

流程

  1. 在 Fuse Online 中,在左侧面板中,单击 Connections 以显示任何可用的连接。
  2. 单击 Create Connection 以显示可用的连接器。连接器是用来创建一个或多个连接的模板。
  3. Twitter 连接器。
  4. 单击 Connect Twitter 以显示 Twitter 授权页面。在看到授权页面前,您可能需要登录 Twitter。

    如果没有出现 Connect Twitter,那么您的 Fuse 在线环境不会作为 Twitter 客户端应用程序注册。请参阅 将 Fuse Online 注册为 Twitter 客户端应用程序。当您尝试创建 Twitter 连接并且 Fuse Online 环境未注册为 Twitter 客户端应用程序时,Fuse Online 会显示多个提示授权信息的字段。虽然您可以通过在这些字段中输入值来创建 Twitter 连接,但不建议这样做。

  5. 单击 Authorize 应用,返回到 Fuse Online。
  6. Name 字段中输入您的选择的名称,帮助您将这个连接与任何其他连接区分开来。例如,输入 Twitter Connect 1
  7. Description 字段中输入任何有助于了解这个连接的信息。例如,输入 使用 my Twitter 登录凭证的 Sample Twitter 连接。
  8. Save 以查看您创建的连接现在可用。如果您输入了示例名称,看 witter Connect 1 显示为可选择添加到集成的连接。

2.3. 将 Fuse Online 注册为 Salesforce 客户端应用程序

在集成中,要连接到 Salesforce,必须首先将 Fuse 在线环境注册为可访问 Salesforce 的客户端应用程序。这可让您创建连接到 Salesforce 的任何数量集成。换句话说,您只需要在 Salesforce 中注册特定的 Fuse 在线环境。

在每个 Fuse 在线环境中,每个 Fuse 在线环境中只能使用一个将 Fuse Online 注册为 Salesforce 客户端应用程序。但是,虽然每个 Salesforce 连接都使用相同的注册,但可以使用不同的用户凭证。

如果您已经将 Fuse Online 注册为 Salesforce 客户端并创建了 Salesforce 连接,请跳至 Creating and deploy the Twitter to Salesforce 集成

前提条件

您已登录到 Fuse Online。

流程

  1. 在 Fuse Online 中:

    1. 在左侧面板中,单击 Settings
    2. Settings 页面中,在回调 URL 右侧,点 Copy Callback URL 将 Fuse Online 环境的回调 URL 复制到剪贴板。在此过程结束时,您将需要这个 URL。
    3. 点击 Salesforce 条目显示 客户端 ID 和客户端 Secret 字段。
  2. 在另一个浏览器标签页中,登录到 Salesforce 帐户,并按照以下步骤创建连接的应用程序。这些说明假设您使用 Salesforce Classic 用户界面。要从 Salesforce Lightning 体验界面切换,请点击您的配置集图标,并选择 切换到 Salesforce Classic。如需更多信息,请参阅有关创建连接应用程序的 Salesforce 文档

    1. 在 Salesforce 中,在右上角点击 Setup
    2. 在左侧面板中,选择 Build > Create > Apps
    3. 向下滚动到 Connected Apps 并点击 New
    4. 输入所需信息,然后选择 Enable OAuth Settings
    5. Callback URL 字段中,粘贴您的 Fuse Online URL,该 URL 在此流程开始时进行复制。例如 :https://app-proj912876.7b63.fuse-ignite.openshiftapps.com/api/v1/credentials/callback
    6. 对于 OAuth 范围,请添加:

      • 通过 API(api)管理用户数据.
      • 访问唯一标识符(openid)
      • 随时执行请求(refresh_token、line_accesss)
    7. 选择 Configure ID 令牌,然后选择 Include Standard Claims
    8. 向下滚动,再单击 Save
    9. 向上滚动以查看 Salesforce 表示短等待: SF message to wait a few minutes
    10. Continue
    11. 复制 Salesforce 提供的消费者密钥。
  3. 返回到您的 Fuse Online Settings 页面,并将 Salesforce 提供的消费者密钥粘贴到 Fuse 在线 Salesforce 客户端 ID 字段中。
  4. 返回 Salesforce 网站并复制 Salesforce 提供的消费者 secret。
  5. 返回到您的 Fuse Online Settings 页面,并将 Salesforce 提供的消费者 secret 粘贴到 Fuse Online Salesforce Client Secret 字段中。
  6. 点击 Save
  7. Salesforce 条目折叠它。

2.4. 创建 Salesforce 连接

要创建可访问 Salesforce 数据的集成,您必须首先创建一个 Salesforce 连接。创建 Salesforce 连接后,您可以在多个集成中使用它。

先决条件

  • 您已登录到 Fuse Online。
  • Fuse Online 在网页浏览器中打开。
  • 您必须已将 Fuse Online 环境注册为可以访问 Salesforce 的应用程序。
  • 您已将注册后的 Salesforce 客户端 ID 和客户端 secret 添加到 Fuse Online Settings 页面。

    如果您还没有注册 Fuse Online,请参阅将 Fuse Online 注册为 Salesforce 客户端应用程序

    在尝试创建 Salesforce 连接之前,请务必在将 Fuse 在线安装注册为 Salesforce 客户端后等待 2 到 10 分钟。

流程

  1. 在 Fuse Online 中,在左侧面板中,单击 Connections 以显示可用的连接。
  2. 单击 Create Connection 以显示可用的连接器。连接器是用于创建一个或多个连接的模板。
  3. Salesforce 连接器。
  4. 点击 Connect Salesforce 显示 Salesforce 授权页面。在看到授权页面前,您可能需要登录到 Salesforce。

    如果没有出现 Connect Salesforce,那么您的 Fuse 在线环境不会作为 Salesforce 客户端应用程序注册。请参阅 将 Fuse Online 注册为 Salesforce 客户端应用程序。当您尝试创建 Salesforce 连接并且 Fuse Online 环境未注册为 Salesforce 客户端应用程序时,Fuse Online 会显示多个提示授权信息的字段。虽然您可以通过在这些字段中输入值来创建 Salesforce 连接,但不建议这样做。

    注意

    以下错误表示 Salesforce 没有正确的 Fuse Online 回调 URL:

    error=redirect_uri_mismatch&error_description=redirect_uri%20must%20match%20configuration

    如果收到这个错误消息,然后在 Salesforce 中确保 Fuse Online 回调 URL 由 Registering Fuse Online 中的说明指定为 Salesforce 客户端应用程序

  5. Allow 返回 Fuse Online。
  6. Name 字段中输入您的选择的名称,帮助您将这个连接与任何其他连接区分开来。例如,输入 SF Connect 1
  7. Description 字段中输入任何有助于了解这个连接的信息。例如,输入 使用我的 Salesforce 登录凭证的 Sample Salesforce 连接。
  8. Save 以查看您创建的连接现在可用。如果您输入了示例名称,您会看到 SF Connect 1 显示为可选择添加到集成的连接。

2.5. 创建并部署到 Salesforce 示例集成

要创建并部署使用您所创建的 Twitter 和 Salesforce 连接的集成,主要步骤如下:

先决条件

  • 将您的 Fuse Online 环境注册为 Twitter 客户端,并创建了 Fuse Online Twitter 连接。
  • 将 Fuse 在线环境注册为 Salesforce 客户端,并创建了 Fuse 在线 Salesforce 连接。
  • Fuse Online 是开放的,您登录了。

2.5.1. 选择启动连接

在 Fuse Online 中,要创建 example Twitter 到 Salesforce 集成,第一项任务是选择启动连接。

先决条件

  • 您创建了 Twitter 连接。

流程

  1. 在左侧,单击 Integrations
  2. Create Integration
  3. Choose a connection 页面上,点击您创建的witter 连接。如果您给出了示例名称,您可以点击 Twitter Connect 1。当集成启动时,它使用此连接中定义的凭证连接到 Twitter。
  4. Select an action 页面上的 Mention action 条目右侧,单击 Select
  5. Configure the action 页面上,单击 Next。不需要配置。

后续步骤

当集成运行时,在连接到 Twitter 后,集成 monitor Twitter 会提到包含您的 Twitter 屏幕名称。匹配会触发集成中的下一步。但是,在添加在连接间操作数据的步骤前,您可以选择集成用来完成其工作的连接。

2.5.2. 选择完成连接

在 Fuse Online 中,要在添加开始连接后继续将 Twitter 到 Salesforce 示例集成,您需要把完成连接添加到集成中。

先决条件

  • 作为启动连接,将 Twitter 连接添加到集成。
  • Fuse Online 正在提示您添加完成连接。
  • 您创建了 Salesforce 连接。

流程

  1. Choose a connection 页面中,点击您创建的 Salesforce 连接。如果您给出了示例名称,您可以点击 SF Connect 1。此集成需要使用此连接中定义的凭证连接到 Salesforce。
  2. Choose a action 页面上,在 New record 条目的右侧,单击 Select
  3. Configure the action 页面上,点 Object name 字段,然后选择 Contact 作为要创建的 Salesforce 记录。
  4. Next 将完成连接添加到集成。

2.5.3. 添加基本过滤器步骤

在 Fuse Online 中,为了继续将 Twitter 到 Salesforce 示例集成,请添加基本的过滤器步骤,检查您提到特定内容。在集成执行时间,仅当其内容存在时,处理才会继续。

先决条件

  • 您添加了 Twitter 连接,作为集成的启动连接。
  • 作为集成完成连接,您刚刚添加了 Salesforce 连接。

流程

  1. 在集成视觉化中,点击加号显示您可以添加到集成的步骤。
  2. 单击 Basic Filter
  3. Property Name 字段中,开始 输入文本,并在字段下方显示文本时单击该文本。Twitter 文本字段 (包含调整内容)是您希望该过滤器评估的数据。
  4. Operator 字段中,接受 包含 作为集成所满足的条件,以便继续进行。
  5. Keywords 字段中,输入 #RedHatIsGreat 或您选择用于检查的值的一些其他文本。涉及的调整内容必须包含您在此处输入的文本,以便集成在此数据上继续运行。
  6. 点击 完成 将基本过滤器步骤添加到集成中。

2.5.4. 添加数据映射步骤

要继续创建 Twitter 到 Salesforce 示例集成,请添加一个数据映射步骤,该步骤与 Twitter 提到了 Salesforce 联系字段。

先决条件

  • 该集成的开始连接是witter。
  • 集成的完成连接是 Salesforce。
  • 您刚刚在两个连接之间添加了过滤器步骤。

流程

  1. 在 Fuse Online 中,在集成视觉化中点击过滤器步骤与完成连接之间的加号。
  2. Data Mapper 并等待几分钟。当显示数据字段时,左侧的 Sources 面板会显示 Twitter 字段和 Target 面板,右侧会显示 Salesforce 字段。
  3. 将 Twitter 名称字段 映射到 Salesforce FirstNameLastName 字段:

    1. Sources 面板中,点放大镜 magnifying glass 以显示搜索字段并输入 名称
    2. 在用户 文件夹下,单击 name 字段,然后单击 Create New Mapping 图标。
    3. Mapping Details 面板中,在 Targets 字段中键入 LastName 来过滤目标字段列表,然后选择 /LastName。data mapper 显示在源名称字段中的行到目标 LastName 字段。
    4. Mapping Details 面板中,在 Targets 字段中键入 FirstName 来过滤目标字段列表,然后选择 /FirstName

      data mapper 从 Twitter 名称字段显示一行,但这一次是 Salesforce FirstName 字段。 蓝线表示当前焦点。

      注意

      如果您意外映射错误的字段,请通过点击 data mapper 的 Mapping Details 面板中的 trash 可以图标来删除不正确的映射。

    5. Mapping Details 面板中,在 Targets 下,确保为 LastName 分配索引 #1FirstName is assigned index #2
  4. 将 Twitter screenName 字段映射到 Salesforce 标题字段:

    1. Sources 面板中点 screenName 字段。
    2. Target 面板的顶部,点放大镜 magnifying glass 以显示搜索字段并输入 标题
    3. title 字段。data mapper 显示在 Salesforce 标题字段中的 Twitter screenName 字段
  5. 将 Twitter 文本字段 映射到 Salesforce Description 字段:

    1. Sources 搜索字段中,输入文本 并点击 文本字段。务必单击顶级 文本字段。不要点击 user 字段中包含的一个 文本字段
    2. Target 搜索字段中,输入描述
    3. 点击 Salesforce Description 字段创建映射。
  6. 在左上角,点网格图标 grid 以显示映射列表,这应如下所示: Data Mappings
  7. 在右上角,单击 Done

2.5.5. 为集成提供名称和部署

当 Twitter 到 Salesforce 示例集成完成后,您可以部署它并查看它的工作方式。

先决条件

  • 该集成的开始连接是witter。
  • 集成的完成连接是 Salesforce。
  • 该集成具有过滤器步骤。
  • 您刚刚向集成添加数据映射步骤。

流程

  1. 在右上角,单击 Publish
  2. Name 字段中输入您选择的名称,将此集成与任何其他集成区分开。例如:witter 到 Salesforce Sample Integration
  3. (可选)在 Description 字段中输入有助于了解此集成的信息。
  4. 另外,还可为集成添加一个或多个自定义环境变量。
  5. 另外,在 Labels 字段中添加一个或多个标签。标签(label)是一个键值对标签,您可以应用到集成以便稍后过滤并在 OpenShift 中选择。例如,OpenShift admin 用户可以按照标签过滤正在运行的 Pod 或部署的列表。
  6. 单击 Save 并发布

    Fuse Online 开始部署集成,然后显示集成摘要。在顶部附近,您可以看到显示发布阶段的进度指示器。Fuse Online 为集成生成运行时,并将在运行时就绪时启动。这只需要几分钟时间。

    Fuse Online 帐户限制为一次可以运行的特定数量集成。详情请查看定价计划。如果您已在运行最大集成数量,那么您必须在开始运行另一个集成前停止集成。

  7. 如果您已在运行最大集成数量,请按照以下步骤停止集成:

    1. 在左侧面板中,点 Integrations
    2. 在您要停止的集成条目中,点击最右侧的 ThreeVerticalDotsKebab
    3. 在弹出窗口中,点击 Stop
  8. 停止集成后,按如下所示启动另一个集成:

    1. 在左侧面板中,点 Integrations
    2. 在您要启动的集成的条目中,点击最右侧的 ThreeVerticalDotsKebab
    3. 在弹出窗口中点击 Start

2.6. 确认 Twitter 到 Salesforce 集成是否正常工作

要确认 Twitter 到 Salesforce 示例集成是否正常工作,请创建一些调整并检查 Salesforce 网站的结果。

先决条件

  • 在 Fuse Online 中,在您发布时为 Twitter 到 Salesforce 示例集成指定的名称旁边会出现 运行
  • 您可以访问您的 Twitter 和 Salesforce 帐户。

流程

  1. 在左侧面板中的 Fuse Online 中,单击 Integration 以查看您创建的集成是 Running 集成。如果您输入了示例名称,您会看到 Twitter 到 Salesforce Sample Integration 正在运行。
  2. 确认当 tweet 不包含您在基本过滤器步骤中指定的文本时集成不会创建联系记录:

    1. 在 Twitter 中,发送一个调整信息:

      • 提到您的 Twitter 处理
      • 不要包含您在基本过滤器步骤中指定的文本

        例如 :@Aslan #likesRedHat。

    2. 等待轮询间隔变为 elapse,这可能为 30 - 60 秒。
    3. 在 Salesforce 系统中,确认没有与用于调整的 Twitter 帐户关联的名称的新联系信息。
  3. 确认集成会在应该时创建一个新的联系记录:

    1. 在 Twitter 中,发送一个调整信息:

      • 提到您的 Twitter 处理
      • 包含您在基本过滤器步骤中指定的文本

        例如 :@Aslan 知道 #RedHatIsGreat。

    2. 等待轮询间隔变为 elapse。
    3. 在 Salesforce 中,请执行以下操作:

      1. 登录到您的常规 Salesforce 帐户,而不是您的 Salesforce 开发人员帐户。
      2. 在您的主页上,在 Recent Items 下,您应看到您的新联系人。
      3. 点击它查看详情。

        新联系人记录应具有与您用于调整的 Twitter 帐户关联的名称。您的 tweet 文本应在 Description 字段中,并且您的 Twitter 屏幕名称应在 title 字段中。

  4. 另外,还可查看集成日志以排除意外结果或了解更多有关集成执行的信息:

    1. 在 Fuse Online 中的左侧面板中,单击 Integrations
    2. 查看您的 Twitter 到 Salesforce 集成。
    3. 在集成概述页面中,点 Activity 选项卡。
    4. 点击您要查看活动信息的集成执行。

2.7. 清理您的集成

处理示例集成后,您应该停止它并删除它,以便将资源用于另一个集成。

先决条件

  • 您已完成一个示例集成。

流程

  1. 在 Fuse Online 中的左侧面板中,单击 Integrations
  2. 在主面板中,找到您要停止的示例集成的条目。
  3. 在该条目中,点 Kebab Menu ,然后点 Stop
  4. Stop 确认您要停止运行集成。
  5. 在您刚刚停止的集成的条目中,点击 Kebab Menu ,然后点 Delete
  6. 点击 Delete 以确认要删除集成。

第 3 章 将 Salesforce 实现到数据库示例集成

这个示例集成会在 Salesforce 中捕获更新,然后调用数据库存储的流程,它将该数据库与 Salesforce 更新同步。

先决条件

  • 您需要一个用于开发环境的 Salesforce 安装中的帐户。此帐户必须具有 Salesforce API 访问权限,该帐户可在 Salesforce Enterprise 帐户或 Salesforce Developer 帐户中可用。要获得免费开发人员帐户,请访问 https://developer.salesforce.com/signup。获取 Salesforce 帐户需要不到两分钟。

    如果您已经为 Salesforce 示例集成创建了 Twitter:

    • Fuse Online 已注册为 Salesforce 客户端。您不需要再次执行此操作。
    • 您已有 Salesforce 连接,您可以在此示例集成中重复使用该连接。

    如果您还没有在 Salesforce 示例集成中创建 Twitter,则必须将 Fuse 在线注册为 Salesforce 客户端,并创建一个 Salesforce 连接,以完成 Salesforce 到数据库示例集成。

  • 您必须登录 Fuse 在线环境。
  • 您在在 OpenShift Container Platform 项目中运行的 Fuse Online 环境中工作,管理员添加了 Fuse Online 示例数据,该数据提供了 PostgresDB 连接和 To Do 应用,以确认该集成可以正常工作。

要实现、部署和测试此示例集成,请运行以下主要步骤:

3.1. 将 Fuse Online 注册为 Salesforce 客户端应用程序

在集成中,要连接到 Salesforce,必须首先将 Fuse 在线环境注册为可访问 Salesforce 的客户端应用程序。这可让您创建连接到 Salesforce 的任何数量集成。换句话说,您只需要在 Salesforce 中注册特定的 Fuse 在线环境。

在每个 Fuse 在线环境中,每个 Fuse 在线环境中只能使用一个将 Fuse Online 注册为 Salesforce 客户端应用程序。但是,虽然每个 Salesforce 连接都使用相同的注册,但可以使用不同的用户凭证。

如果您已经将 Fuse Online 注册为 Salesforce 客户端并创建了 Salesforce 连接,请跳至 创建和部署 Salesforce 到数据库集成

前提条件

您已登录到 Fuse Online。

流程

  1. 在 Fuse Online 中:

    1. 在左侧面板中,单击 Settings
    2. Settings 页面中,在回调 URL 右侧,点 Copy Callback URL 将 Fuse Online 环境的回调 URL 复制到剪贴板。在此过程结束时,您将需要这个 URL。
    3. 点击 Salesforce 条目显示 客户端 ID 和客户端 Secret 字段。
  2. 在另一个浏览器标签页中,登录到 Salesforce 帐户,并按照以下步骤创建连接的应用程序。这些说明假设您使用 Salesforce Classic 用户界面。要从 Salesforce Lightning 体验界面切换,请点击您的配置集图标,并选择 切换到 Salesforce Classic。如需更多信息,请参阅有关创建连接应用程序的 Salesforce 文档

    1. 在 Salesforce 中,在右上角点击 Setup
    2. 在左侧面板中,选择 Build > Create > Apps
    3. 向下滚动到 Connected Apps 并点击 New
    4. 输入所需信息,然后选择 Enable OAuth Settings
    5. Callback URL 字段中,粘贴您的 Fuse Online URL,该 URL 在此流程开始时进行复制。例如 :https://app-proj912876.7b63.fuse-ignite.openshiftapps.com/api/v1/credentials/callback
    6. 对于 OAuth 范围,请添加:

      • 通过 API(api)管理用户数据.
      • 访问唯一标识符(openid)
      • 随时执行请求(refresh_token、line_accesss)
    7. 选择 Configure ID 令牌,然后选择 Include Standard Claims
    8. 向下滚动,再单击 Save
    9. 向上滚动以查看 Salesforce 表示短等待: SF message to wait a few minutes
    10. Continue
    11. 复制 Salesforce 提供的消费者密钥。
  3. 返回到您的 Fuse Online Settings 页面,并将 Salesforce 提供的消费者密钥粘贴到 Fuse 在线 Salesforce 客户端 ID 字段中。
  4. 返回 Salesforce 网站并复制 Salesforce 提供的消费者 secret。
  5. 返回到您的 Fuse Online Settings 页面,并将 Salesforce 提供的消费者 secret 粘贴到 Fuse Online Salesforce Client Secret 字段中。
  6. 点击 Save
  7. Salesforce 条目折叠它。

3.2. 创建 Salesforce 连接

要创建可访问 Salesforce 数据的集成,您必须首先创建一个 Salesforce 连接。创建 Salesforce 连接后,您可以在多个集成中使用它。

先决条件

  • 您已登录到 Fuse Online。
  • Fuse Online 在网页浏览器中打开。
  • 您必须已将 Fuse Online 环境注册为可以访问 Salesforce 的应用程序。
  • 您已将注册后的 Salesforce 客户端 ID 和客户端 secret 添加到 Fuse Online Settings 页面。

    如果您还没有注册 Fuse Online,请参阅将 Fuse Online 注册为 Salesforce 客户端应用程序

    在尝试创建 Salesforce 连接之前,请务必在将 Fuse 在线安装注册为 Salesforce 客户端后等待 2 到 10 分钟。

流程

  1. 在 Fuse Online 中,在左侧面板中,单击 Connections 以显示可用的连接。
  2. 单击 Create Connection 以显示可用的连接器。连接器是用于创建一个或多个连接的模板。
  3. Salesforce 连接器。
  4. 点击 Connect Salesforce 显示 Salesforce 授权页面。在看到授权页面前,您可能需要登录到 Salesforce。

    如果没有出现 Connect Salesforce,那么您的 Fuse 在线环境不会作为 Salesforce 客户端应用程序注册。请参阅 将 Fuse Online 注册为 Salesforce 客户端应用程序。当您尝试创建 Salesforce 连接并且 Fuse Online 环境未注册为 Salesforce 客户端应用程序时,Fuse Online 会显示多个提示授权信息的字段。虽然您可以通过在这些字段中输入值来创建 Salesforce 连接,但不建议这样做。

    注意

    以下错误表示 Salesforce 没有正确的 Fuse Online 回调 URL:

    error=redirect_uri_mismatch&error_description=redirect_uri%20must%20match%20configuration

    如果收到这个错误消息,然后在 Salesforce 中确保 Fuse Online 回调 URL 由 Registering Fuse Online 中的说明指定为 Salesforce 客户端应用程序

  5. Allow 返回 Fuse Online。
  6. Name 字段中输入您的选择的名称,帮助您将这个连接与任何其他连接区分开来。例如,输入 SF Connect 1
  7. Description 字段中输入任何有助于了解这个连接的信息。例如,输入 使用我的 Salesforce 登录凭证的 Sample Salesforce 连接。
  8. Save 以查看您创建的连接现在可用。如果您输入了示例名称,您会看到 SF Connect 1 显示为可选择添加到集成的连接。

3.3. 创建并部署 Salesforce 到数据库示例集成

要创建并部署使用您创建的 Salesforce 连接以及随 Fuse Online 提供的数据库连接的集成,主要步骤如下:

先决条件

  • 将 Fuse 在线环境注册为 Salesforce 客户端。
  • 您创建了 Fuse 在线 Salesforce 连接。
  • Fuse Online 是开放的,您登录了。

3.3.1. 选择启动连接

在 Fuse Online 中,为创建示例 Salesforce 到数据库集成,第一项任务是选择开始连接。

先决条件

  • 您创建了 Salesforce 连接。

流程

  1. 在 Fuse Online 中,单击左侧的 Integrations
  2. Create Integration
  3. Choose a connection 页面中,点击您的 Salesforce 连接。如果指定了示例名称,您可以点击 SF Connect 1
  4. 在 Select an action 页面上的 On create 右侧,单击 Select
  5. Object name 字段中,选择 leader
  6. Next 将开始连接添加到集成。

后续步骤

当集成运行时,在连接到 Salesforce 后,集成会监视创建 Salesforce 网站记录的通知。当集成发现此类通知时,它会将新产生的数据传递给集成中的下一步。但是,在添加下一步之前,您必须选择集成的完成连接。

3.3.2. 选择完成连接

在 Fuse Online 中,在添加开始连接后继续将 Salesforce 创建到数据库示例集成,您需要把完成连接添加到集成中。

先决条件

  • 作为启动连接,已将 Salesforce 连接添加到集成。
  • Fuse Online 正在提示您添加完成连接。

流程

  1. 在 Fuse Online 中,在 Choose a connection 页面上,单击 PostgresDB 连接。此集成使用此数据库连接中定义的凭据来连接提供的示例数据库,从而完成此集成。
  2. 在 Choose a action 页面上,选择 Invoke stored procedure,它将数据传递给存储的步骤。
  3. Procedure name 字段中,接受 add_lead,这是在示例数据库中运行时提供的存储流程。所选步骤决定了集成中的其他步骤的要求,例如: Salesforce data 字段需要映射到哪些数据库字段。
  4. Next 将完成连接添加到集成。

3.3.3. 添加数据映射步骤

要继续创建 Salesforce 到数据库示例集成,请将 Salesforce 领导字段相关联到示例数据库中的字段的数据映射步骤。

先决条件

  • 该集成的开始连接是 Salesforce 上的。
  • 集成的完成连接是 PostgresDB 示例数据库。

流程

  1. 在 Fuse Online 中,在集成视觉化中点加号。
  2. Data Mapper 并等待几分钟。当显示数据字段时,左侧的 Sources 面板会显示 Salesforce 字段和 Target 面板,右侧显示数据库字段。
  3. 将 Salesforce Company 字段映射到数据库 公司 字段。在左侧,在 Sources 面板中,单击 Company,并将它拖到 公司 目标 面板中。

    data mapper 显示来自 source 字段的行到 target 字段。

  4. Sources (Salesforce) Email 字段映射到 Target (database) 电子邮件 字段。
  5. 将两个 Salesforce 字段(FirstNameLastName)映射到数据库 first_and_last_name 字段:

    1. Target 面板中,点 first_and_last_name,然后单击 Create New Mapping 图标。
    2. Mapping Details 面板中,在 Sources 字段中选择 /FirstName,然后选择 /LastName

      完成后,您应该会看到从每个源字段到 target 字段的行。

  6. 添加以下映射:

    映射此 Salesforce 字段到此数据库字段

    LeadSource

    lead_source

    状态

    lead_status

    电话

    phone

    评级

    评级

  7. 在右上角,单击 Done

3.3.4. 为集成提供名称和部署

当 Salesforce 到数据库示例集成完成后,您可以部署它并查看它的工作方式。

先决条件

  • 该集成的开始连接是 Salesforce。
  • 该集成的完成连接是随 Fuse Online 提供的示例数据库。
  • 您刚刚向集成添加数据映射步骤。

流程

  1. 在 Fuse Online 中,单击 Publish 以为其命名。
  2. Name 字段中输入集成的名称。例如,Salesforce 到数据库示例集成
  3. (可选)在 Description 字段中输入有助于了解此集成的信息。
  4. 另外,在 Labels 字段中添加一个或多个标签。标签(label)是一个键值对标签,您可以应用到集成以便稍后过滤并在 OpenShift 中选择。例如,OpenShift admin 用户可以按照标签过滤正在运行的 Pod 或部署的列表。
  5. 单击 Save 并发布

    Fuse Online 开始部署集成,然后显示此环境中集成的列表。您的 Salesforce 到数据库集成的条目会显示一个进度指示符,显示发布阶段。Fuse Online 为集成生成运行时,并将在运行时就绪时启动。这只需要几分钟时间。

    Fuse Online 帐户限制为一次可以运行的特定数量集成。详情请查看定价计划。如果您已在运行最大集成数量,那么您必须在开始运行另一个集成前停止集成。

  6. 如果您已在运行最大集成数量,请按照以下步骤停止集成:

    1. 在左侧面板中,点 Integrations
    2. 在您要停止的集成条目中,点击最右侧的 ThreeVerticalDotsKebab
    3. 在弹出窗口中,点击 Stop
  7. 停止集成后,按如下所示启动另一个集成:

    1. 在左侧面板中,点 Integrations
    2. 在您要启动的集成的条目中,点击最右侧的 ThreeVerticalDotsKebab
    3. 在弹出窗口中,单击 Publish

3.4. 确认 Salesforce 到数据库集成是否正常工作

要确认 Salesforce 到数据库集成正常工作,请创建一个 Salesforce 网站,然后打开 Fuse Online 为查看示例数据库的 Web 应用程序。

先决条件

  • 在 Fuse Online 中,您发布时为 Salesforce 指定的名称旁边会出现 运行运行
  • 您可以访问您的 Salesforce 账户。

流程

  1. 在左侧面板中,点 Integrations
  2. 如有必要,请等待示例集成处于 Running 的集成。如果您使用了示例名称,您会看到 Salesforce to Database Sample IntegrationRunning
  3. 在您的 Salesforce 安装中,创建一个新的销售线索。请务必在映射的字段中输入数据: 公司电子邮件名字、姓氏、head Name、headSourceStatusPhoneRating
  4. 在新的浏览器窗口中,在 Fuse 在线环境的 URL 前插入 todo-。例如 :http://todo-app-proj761432.6a63.fuse-ignite.openshiftapps.com/

    您的 Fuse 在线环境提供了 To Do 应用,具有用于访问包含任务的数据库的 REST API。在 AMQ to REST API 示例集成指南中,提供了上传 To Do 应用的 OpenAPI 文档以创建一个 API 客户端连接器的说明。

  5. To Do App 显示中,您应该会看到数据库中创建了一个新领导的通知。
  6. 另外,还可查看集成日志以排除意外结果或了解更多有关集成执行的信息:

    1. 在 Fuse Online 中的左侧面板中,单击 Integrations
    2. 查看您的 Salesforce 到数据库集成。
    3. 在集成概述页面中,点 Activity 选项卡。
    4. 点击您要查看活动信息的集成执行。

3.5. 清理您的集成

处理示例集成后,您应该停止它并删除它,以便将资源用于另一个集成。

先决条件

  • 您已完成一个示例集成。

流程

  1. 在 Fuse Online 中的左侧面板中,单击 Integrations
  2. 在主面板中,找到您要停止的示例集成的条目。
  3. 在该条目中,点 Kebab Menu ,然后点 Stop
  4. Stop 确认您要停止运行集成。
  5. 在您刚刚停止的集成的条目中,点击 Kebab Menu ,然后点 Delete
  6. 点击 Delete 以确认要删除集成。

第 4 章 实现 AMQ 到 REST API 示例集成

此示例集成连接到 Red Hat AMQ 代理,以获取假设企业的项目交付记录。然后,集成会执行在记录上运行的自定义步骤,以识别收到所损坏的项目。在简单的数据映射后,集成会连接到 REST API,以获取供应商损坏项目的联系信息。

其他样本集成使用内置于 Fuse Online 中的连接器和数据操作。这种集成还这样做,但另外,它还提供了通过以下过程自定义和扩展 Fuse Online 的说明:

  • 通过上传扩展名来添加自定义数据操作。
  • 通过上传 OpenAPI 文档来添加自定义 REST API 客户端连接器。

Fuse Online 提供扩展文件和 OpenAPI 文档。

先决条件

  • 您必须登录 Fuse Online。
  • 您在在 OpenShift Container Platform 项目中运行的 Fuse Online 环境中工作,管理员添加了 Fuse Online 示例数据,其提供示例 PostgresDB 连接、AMQ Broker 和 To Do 应用,以确认集成可以正常工作。

要实现 AMQ 到 REST API 示例集成,主要步骤包括:

4.1. 创建 AMQ 连接

AMQ 到 REST API 示例集成首先连接到 OpenShift 项目中提供的 AMQ 代理(Red Hat AMQ)。在开始创建集成本身前,您必须启动代理并创建与该代理的连接。

流程

  1. 验证代理是否已启动:

    1. 在一个浏览器中,进入 OpenShift Web 控制台。
    2. 在控制台中,单击 Project
    3. Overview 页面上的 Inventory 部分中,单击 Services
    4. 单击 broker-amq-tcp,然后单击 Pods。pod 的状态应该是 Running
  2. 创建 AMQ 连接:

    1. 在 Fuse Online 中,在左侧面板中,单击 Connections 以显示任何可用的连接。
    2. 单击 Create Connection 以显示 Fuse Online 连接器。
    3. 点击 Red Hat AMQ 连接器。
    4. 输入以下内容来配置连接:

      1. Broker URL 字段中,输入 tcp://broker-amq-tcp:61616 作为从中获取数据的位置。
      2. User name 字段中,输入 amq 作为访问此 AMQ 代理的帐户的用户名。
      3. Password 字段中,输入 topSecret 作为访问此 AMQ 代理的帐户的密码。
      4. 将其他字段留空。
    5. 单击 Validate。Fuse Online 立即尝试验证连接并显示一条消息,指示验证是否成功。如果验证失败,请检查您输入的值并重试。
    6. 验证成功后,单击 下一步
    7. Name 字段中输入您的选择的名称,帮助您将这个连接与任何其他连接区分开来。例如,输入 Red Hat AMQ Broker 1
    8. Description 字段中输入任何有助于了解这个连接的信息。例如,输入 连接提供的 Red Hat AMQ 消息代理。
    9. Save 以查看您创建的连接现在可用。如果您输入了示例名称,您会看到 Red Hat AMQ Broker 1 现已可用。

4.2. 使自定义步骤可用

Fuse Online 提供了很多在连接间集成数据的操作步骤。如果 Fuse Online 没有提供满足您需求的跨值步骤,开发人员可以编写一个扩展程序,用于定义一个或多个自定义步骤,以便在连接间操作。开发人员会为您提供包含该扩展名的 .jar 文件。然后您上传 Fuse Online 中的扩展,以使自定义步骤可用于集成。

AMQ 到 REST API 示例集成使用一个自定义步骤,在连接之间进行数据运行,以识别收到时损坏的项目。

流程

  1. 在新的浏览器标签页中,转至 https://github.com/syndesisio/fuse-online-sample-extension/releases
  2. 下载 Damage Reporter 扩展的 .jar 文件。
  3. 在 Fuse Online 中,在左侧面板中,单击 Customizations > Extensions
  4. Import Extension
  5. 单击句点框中,再选择包含该扩展名的下载的 .jar 文件。Fuse Online 验证文件,提取并显示扩展 ID、名称、描述和类型,并将 Damage Reporter 列为扩展名定义的自定义步骤。
  6. Import Extension。Fuse Online 使自定义步骤可用,并显示已导入的扩展列表。

其他资源

有关编码扩展并创建 .jar 文件的详情,请参考:

4.3. 创建 REST API 连接器

Fuse Online 可以为 REST API 创建连接器,以支持 Hypertext 传输协议(HTTP)/1.0 或 HTTP/1.1。要做到这一点,Fuse Online 需要有效的 OpenAPI 3(或 2)文档,用于描述您要连接的 REST API。

您的 Fuse 在线环境提供了 To Do 应用,具有用于访问包含任务的数据库的 REST API。您的环境还为这个 API 提供 OpenAPI 文档。

流程

  1. 下载 todo 应用的图标

    1. 在 Fuse Online 导航面板中点 Home
    2. 将 URL 复制到文本编辑器中。
    3. 在 URL 的开头,插入 todo-
    4. 在 URL 的末尾,添加 /images/todo_icon.png
    5. 使用 http 方案而不是 https

      其结果如下: http://todo-app-proj217402.6a63.fuse-ignite.openshiftapps.com/images/todo_icon.png

    6. 将此 URL 粘贴到新的浏览器窗口中,并将 todo_icon.png 文件下载到文件系统中的位置。您将在第 11 步中上传此图标。
  2. 识别 Fuse Online 环境对 OpenAPI 文档的副本的 URL:

    1. 在 Fuse Online 导航面板中点 Home
    2. 将 URL 复制到文本编辑器中。
    3. 在 URL 的开头,插入 todo-
    4. 在 URL 的末尾,添加 swagger.json
    5. 使用 http 方案而不是 https

      其结果如下: http://todo-app-proj217402.6a63.fuse-ignite.openshiftapps.com/swagger.json

    注意

    指定 http 而不是 https,如果 TLS 证书无效,则会避免运行时错误。在生产环境中,确保有效的证书就位,并且始终指定安全 URL(https)来获取 OpenAPI 文档。

  3. 在 Fuse Online 导航面板中,点击 Customizations > API Client Connectors
  4. Create API Connector
  5. 选择" 使用 URL "。
  6. 在输入框中,粘贴 OpenAPI 文档的 URL 并点 Next
  7. Review Actions 页面中,点 Next。如果您看到警告,您可以忽略它。
  8. 点击 Next
  9. Specify Security 页面中,接受 HTTP Basic Authentication 并指定用户名和密码,如 adminadmin。请注意,对于本示例应用程序,不会验证用户名和密码。
  10. 点击 Next
  11. Todo App API 概述页面中:

    1. 对于 Connector Icon,请单击 Choose File,然后导航到您在步骤 1 中下载的 todo_icon.png 的位置。
    2. 如果要,可以在 NameDescription 字段中更改值。
    3. Host 字段中,接受服务主机的名称,即 http://todo-app-proj217402.6a63.fuse-ignite.openshiftapps.com
    4. Base URL 字段中,接受与服务请求中的主机名后面的 URL 的一部分: /api
  12. 点击 Save

    Fuse Online 显示 API 客户端连接器。刚刚创建的 Todo App API 有一个新条目。

4.4. 创建 REST API 连接

在集成中,在连接到 REST API 之前,您可以创建一个 REST API 客户端连接器,然后使用该连接器来创建连接。您已为 To Do 应用创建了 REST API 连接器。按照此处的说明,使用该连接器创建与 To Do 应用 REST API 的连接。

前提条件

  • 您创建了 Todo App REST API 连接器。

流程

  1. 在 Fuse Online 中,在左侧面板中,单击 Connections 以显示任何可用的连接。
  2. 单击 Create Connection 以显示可用的连接器。
  3. 点击您刚才创建的 Todo App API 连接器。

    Fuse Online 从 OpenAPI 文档填充您在创建连接器时提供的 HostBase Path 字段。

  4. Username 字段中输入任何值。在本示例集成中,需要用户名和密码值,但不会使用它们。
  5. Password 字段中输入任何值。
  6. 点击 Next
  7. Name 字段中输入您的选择的名称,帮助您将这个连接与任何其他连接区分开来。例如,输入 Todo App API Client
  8. Description 字段中输入任何有助于了解这个连接的信息。例如,输入 Connection to the provided Todo app REST API。
  9. Save 以查看您创建的连接现在可用。

4.5. 创建并部署 AMQ 到 REST API 示例集成

要创建并部署 AMQ 到 REST API 示例集成,主要步骤如下:

先决条件

  • 您创建了与提供的 Red Hat AMQ 代理的连接。
  • 您创建了与提供的 Todo 应用的 API 客户端连接。
  • 您上传了提供 Damage Reporter 步骤的扩展。

4.5.1. 选择启动连接

在 Fuse Online 中,为创建 AMQ 到 REST API 示例集成,第一项任务是选择启动连接。

先决条件

  • 您启动了提供的 Red Hat AMQ 代理。
  • 您创建了与该消息代理的连接。

流程

  1. 在 Fuse Online 中,单击左侧的 Integrations
  2. Create Integration
  3. Choose a connection 页面中,点击 AMQ 连接。如果指定了示例名称,您可以点击 Red Hat AMQ Broker 1
  4. Choose a action 页面中,选择 Subscribe for message action 以接收来自您指定的队列的消息。
  5. Destination name 字段中,输入 inventoryReceived 作为队列的名称,以便从中获取数据。
  6. Destination type 字段中,单击 Queue
  7. 将其他字段留空。
  8. 点击 Next。Fuse Online 会提示您输入输出数据类型。此示例集成不需要这样做。
  9. Next 将开始连接添加到集成。

后续步骤

当集成运行时,在连接到 Red Hat AMQ 后,集成会监视 inventoryReceived 队列中的消息。当消息可用时,该集成会将其传递到 Damage Reporter 步骤。但是,在将步骤添加到集成前,您必须选择集成的完成连接。

4.5.2. 选择完成连接

在 Fuse Online 中,要在添加启动连接后继续将 AMQ 到 REST API 示例集成,您需要为集成添加完成连接。

先决条件

  • 您上传了提供的 OpenAPI 文档,以创建 Todo App API 连接器。
  • 您可以使用 Todo App API 连接器来创建 Todo App API 连接。

流程

  1. 在 Fuse Online 中,在 Choose a connection 页面上,单击您创建的 To Do app 连接。如果您分配了示例名称,您可以点击 Todo App API Client
  2. 在 Choose a action 页面上,选择 Create new task,它将提供有关谁联系以解决特定损坏项的信息。
  3. Next 将完成连接添加到集成。

4.5.3. 添加损坏的报告器步骤

开始和完成连接就位后,您已准备好添加从 Red Hat AMQ 代理接收消息的自定义步骤,并确定在收到时损坏的任何事项。

前提条件

  • 您上传了提供 Damage Reporter 自定义步骤的扩展。
  • 您添加了开始并完成与集成的连接。

流程

  1. 在 Fuse Online 中,在集成视觉化中点加号。
  2. 单击 Damage Reporter
  3. 点击 Next 将 Damage Reporter 步骤添加到集成中。

4.5.4. 添加数据映射步骤

要继续创建 AMQ 到 REST API 示例集成,您需要添加数据映射步骤。此步骤将输出 中的任务 字段与 REST API 访问的数据库 中的任务 字段相关联。

前提条件

  • 您已将 Damage Reporter 步骤添加到集成中。

流程

  1. 在 Fuse Online 中,在集成视觉化中点击 Damage Reporter 步骤与完成连接之间的加号。
  2. Data Mapper。在 data mapper 中,左侧的 Source 面板显示来自损坏报告器步骤的输出中的字段。右侧的 Target 面板显示 API 访问的数据库中的字段。
  3. Source 面板中,点 Task 字段,然后点 Create New Mapping 图标。

    此时会打开 Mapping Details 面板。

  4. Mapping Details 目标面板中,在 Targets 下选择 /body/task
  5. 在右上角,单击 Done

结果

集成已完成,准备好发布。在左侧,在集成视觉化面板中,您可能会看到 warning Data Type Mismatch 警告图标。您可以忽略它。

4.5.5. 为集成提供名称和部署

当一个 Red Hat AMQ 启动连接、一个数据映射程序、数据映射程序以及一个 Todo App Client API 连接时,AMQ to REST API 示例集成已完成。按照这里的说明进行部署。

先决条件

  • 您添加了开始并完成与集成的连接。
  • 您可以在开始和完成连接之间添加了一个 Damager Reporter 步骤。
  • 您会在 Damage Reporter 步骤和到 Todo App API 的连接之间添加了一个数据映射步骤。

流程

  1. 在 Fuse Online 中,单击 Publish
  2. Name 字段中输入集成的名称。例如,AMQ 到 REST API Sample Integration
  3. (可选)在 Description 字段中输入有助于了解此集成的信息。
  4. 另外,还可为集成添加一个或多个自定义环境变量。
  5. 另外,在 Labels 字段中添加一个或多个标签。标签(label)是一个键值对标签,您可以应用到集成以便稍后过滤并在 OpenShift 中选择。例如,OpenShift admin 用户可以按照标签过滤正在运行的 Pod 或部署的列表。
  6. 在右上角,单击 Save 并发布

    Fuse Online 开始部署集成,然后显示此环境中集成的列表。在 AMQ 到 REST API 集成的条目中,您可以看到显示发布阶段的进度指示器。Fuse Online 为集成生成运行时,并将在运行时就绪时启动。这只需要几分钟时间。

    Fuse Online 帐户限制为一次可以运行的特定数量集成。详情请查看定价计划。如果您已在运行最大集成数量,那么您必须在开始运行另一个集成前停止集成。

  7. 如果您已在运行最大集成数量,请按照以下步骤停止集成:

    1. 在左侧面板中,点 Integrations
    2. 在您要停止的集成条目中,点击最右侧的 ThreeVerticalDotsKebab
    3. 在弹出窗口中,点击 Stop
  8. 停止集成后,按如下所示启动另一个集成:

    1. 在左侧面板中,点 Integrations
    2. 在您要启动的集成的条目中,点击最右侧的 ThreeVerticalDotsKebab
    3. 在弹出窗口中点击 Start

4.6. 确认 AMQ 到 REST API 集成可以正常工作

创建并发布 AMQ 到 REST API 示例集成后,您可以确认它是否按照定义进行。

前提条件

在 Fuse Online 中,在集成列表中,AMQ 旁边会出现您创建和部署的 REST API 集成。

流程

  1. 在新的浏览器窗口中,通过在 Fuse 在线环境的 URL 前插入 todo-,转至 To Do 应用显示。例如 :http://todo-app-proj761432.6a63.fuse-ignite.openshiftapps.com/
  2. 在 To Do app 显示中,单击 Show JMS Form 以显示包含 XML 消息的输入框。
  3. 点击 Send JMS Message 将该消息发送到 OpenShift 项目中的 Red Hat AMQ 代理。

    成功执行会返回来自 To Do app client API 的任务。该任务标识已损坏项目的 ID,及其供应商的联系信息。如果任务之前未出现,则尝试重新加载页面。

  4. 编辑 XML 消息来指定两个损坏的项:

    1. 单击 Show JMS Form 以再次显示消息输入框。
    2. 在 XML 消息中,将 undamaged 项的条目更改为指定 已损坏="true"。
    3. 单击 Send JMS Message。To Do app client API 返回一个新任务,其中包含两个供应商的两个已损坏的项目的 ID。
  5. 编辑 XML 信息以指定您组成的 ID:

    1. 单击 Show JMS Form
    2. 在 XML 消息中,对于已损坏 ="true" 的项目,请将项目 ID 更改为 1234
    3. 单击 Send JMS Message。To Do app client API 返回一个新任务,带有您刚刚输入的项目 ID。
  6. 另外,还可查看集成日志以排除意外结果或了解更多有关集成执行的信息:

    1. 在 Fuse Online 中的左侧面板中,单击 Integrations
    2. 查看 AMQ 的条目以 REST API 集成。
    3. 在集成概述页面中,点 Activity 选项卡。
    4. 点击您要查看活动信息的集成执行。

4.7. 清理您的集成

处理示例集成后,您应该停止它并删除它,以便将资源用于另一个集成。

先决条件

  • 您已完成一个示例集成。

流程

  1. 在 Fuse Online 中的左侧面板中,单击 Integrations
  2. 在主面板中,找到您要停止的示例集成的条目。
  3. 在该条目中,点 Kebab Menu ,然后点 Stop
  4. Stop 确认您要停止运行集成。
  5. 在您刚刚停止的集成的条目中,点击 Kebab Menu ,然后点 Delete
  6. 点击 Delete 以确认要删除集成。

法律通告

Copyright © 2023 Red Hat, Inc.
本文档内容及图解由红帽根据 Creative Commons Attribution–Share Alike 3.0 Unported license ("CC-BY-SA")授权。有关 CC-BY-SA 的解释,请访问 http://creativecommons.org/licenses/by-sa/3.0/。根据 CC-BY-SA,如果发布本文档或提供此文档,则必须提供原始版本的 URL。
作为本文档的许可者,红帽可能会放弃强制制执行 CC-BY-SA 第4d 条款,且不声明该条款在适用条款允许的最大限度内有效。
Red Hat、Red Hat Enterprise Linux、Shadowman 商标、JBoss、OpenShift、Fedora、Infinity 商标以及 RHCE 都是在美国及其他国家的注册商标。
Linux® 是 Linus Torvalds 在美国和其它国家的注册商标。
Java® 是 Oracle 和/或其附属公司的注册商标。
XFS® 是 Silicon Graphics International Corp. 或其子公司在美国和/或其他国家的商标。
MySQL® 是 MySQL AB 在美国、欧盟和其他国家/地区的注册商标。
Node.js® 是 Joyent 的官方商标。Red Hat Software Collections 与官方 Joyent Node.js 开源或商业项目没有正式关联或被正式认可。
OpenStack® Word Mark 和 OpenStack 徽标是 OpenStack Foundation 在美国和其它国家的注册商标/服务标记或商标/服务标记,并被 OpenStack Foundation 授权使用。我们不附属于 OpenStack Foundation 或 OpenStack 社区。
Amazon Web Services®、AWS 徽标和 DynamoDB 标识的图标是 Amazon.com, Inc. 在美国和/或其他国家/地区的注册商标。
所有其他商标均由其各自所有者所有。