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

步骤

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

5. 配置 Read 操作：

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

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

      您可以指定 Entity Key Predicate 和 Query Options。如果您这样做，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')

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

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

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

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

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

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

      例如，假设轮询间隔( 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。