19.2. 在轮询从 OData 服务返回数据时触发集成

流程

1. 在左侧的 Fuse Online 面板中，单击 Integrations。
2. 点 Create Integration。
3. 在 Choose a connection 页面中，点您要用来开始集成的 OData 连接。
4. 在 Choose a action 页面中，选择 Read 操作。

5. 配置 Read 操作：

   1. 在 Resource Collection 字段中，选择要查询的 OData 资源的名称。Fuse Online 从 OData 服务获取数据，以提供可用资源集合的列表。
   2. 在 实体密钥 Predicate 字段中，若要获取特定实体，通过指定密钥 predicate 来识别您想要的实体。例如，指定诸如 UserName='Bob' 或 Categories(1) 的内容。要获得多个实体，请将此字段留空。

   3. 在 Query Options 字段中输入您要应用到资源的查询。使用 OData 语法。例如，$filter=startswith(name, 'N') 为资源中有一个 名称字段 以 N 开头。

      您可以指定 实体键假定和查询 选项 。如果您这样做，OData 服务会获取指定的实体，并将查询应用到该实体。例如，假设您将 Entity Key Predicate 设置为 UserName='russellwhyte'/Emails，并将 Query Options 设置为 $filter=contains($it,'example')。连接会创建一个请求，请求类似如下：

      https://services.odata.org/TripPinRESTierService/People(UserName='russellwhyte')/Emails?$filter=contains($it, 'example')

      Copy to Clipboard Toggle word wrap

      该服务会返回包含域 示例 的所有电子邮件地址。

   4. 选择 Filter Old Results 复选框，以只获取特定消息一次。

   5. 如果您希望连接返回单个消息而不是消息集合，请选择 Split Results 复选框。

      Fuse Online 还提供了离散的分割和聚合步骤，您可将其添加到一个流中。如果要在一个或多个步骤中处理各个消息，然后将消息聚合到一个集合中，请不要选择 Split Results 复选框。相反，复选框留空，然后在此连接后向流添加一个拆分步骤。如果您希望流程中的聚合步骤，则需要分割步骤。

   6. 在 Interval Before Poling Starts 字段中，接受默认值 1 秒，或者输入在连接开始轮询 OData 服务前希望放弃的时长。
   7. 在 Delay 字段中，接受默认值 30 秒，或者输入您要连接轮询 OData 服务的时间间隔。

   8. 在 Backoff Idle Threshold 字段中，接受默认值 1 或输入一个整数，表示可以返回任何数据的连续轮询数。轮询次数后，连接会增加后续轮询之间的间隔。连接通过 Backoff Multiplier 值乘以 Delay 值来确定轮询间隔的新长度。

      例如，假设轮询间隔（ Delay 值）是默认值 30 秒，则 Backoff Idle Threshold 被设置为 5，Backoff Multiplier 被设置为 12。5 连续轮询返回任何数据后，连接会在重新轮询前等待 360 秒(30 x 12)。连接会每 360 秒轮询一次，直到轮询返回数据。轮询返回数据后，连接每 30 秒恢复一次轮询。

   9. 在 Backoff Multiplier 字段中，接受默认值 1 或输入整数，如果达到 Backoff Idle Threshold 的值，则代表增加轮询间隔的倍数。

      如果您接受 Backoff Multiplier 的默认 1，那么无论连续的轮询返回任何结果，连接会以指定间隔继续轮询。

      为 Backoff Idle Threshold 和 Backoff Multiplier 指定的值有助于减少 CPU 开销，因为连接可以在静默期间自动轮询频率。

6. 点击 Next。