将 HTTP 源添加到事件流(预览版)

本文介绍如何将 HTTP 源添加到事件流。

HTTP 连接器提供无代码可配置的方式,用于将任何 REST API 中的数据直接流式传输到 Eventstream 中,以便进行实时处理。 它允许你持续从 SaaS 平台和公共数据馈送提取数据,并自动将 JSON 响应分析为结构化事件。 它还提供示例公共源来帮助你快速入门-只需选择示例 API,输入 API 密钥,让 Eventstream 预填充所需的标头和参数。

先决条件

  • 使用参与者或更高权限在 Fabric 容量许可证模式(或)试用许可证模式下访问工作区。
  • 如果没有事件流,请创建一个事件流

将 HTTP 添加为源

如果尚未将任何源添加到事件流,请选择 “使用外部源 ”磁贴。

显示选择用于外部源的磁贴的屏幕截图。

如果要将源添加到已发布的事件流,请切换到 “编辑 ”模式。 在功能区上,选择 “添加源>外部源”。

显示用于添加外部源的选择的屏幕截图。

搜索 http,然后选择 “连接 ”将 HTTP 连接器添加到事件流。

显示选择 HTTP 作为数据源向导中的源类型的屏幕截图。

配置并连接到 HTTP

  1. 在向导中,可以选择一个 示例公共 API 以快速开始使用预定义的标头和参数,或选择 Exit 来配置自己的 HTTP 连接器。

  2. 下面是可用于快速开始使用 HTTP 连接器的示例公共 API:

    • Binance - 获取最新的比特币价格
    • CoinGecko - 获取当前的比特币价格(以美元为单位)
    • 伦敦交通 - 获取伦敦车站的实时到达预测
    • Alpha Vantage - 获取实时 MSFT 股票价格
    • OpenWeather - 获取位置的天气预报
    • NewsAPI - 获取美国的最新商业头条新闻

    显示示例 API 页的屏幕截图。

  3. 或者,选择 “退出 ”以跳过示例并配置自己的 HTTP 连接,而无需示例。

    显示未附带示例的 API 屏幕截图。

  4. 如果选择示例 API,请选择 Eventstream 是否在 “应用”示例之前自动创建连接:

    • 为我创建新连接:自动创建连接并预填充所需的 HTTP 标头和参数。
    • 如果选择此选项,则需要输入 API 密钥来创建连接,但使用 Binance 时不需要 API 密钥。
    • 如果选择 “使用现有连接”,则仅预填充标头和参数,并且需要手动创建连接。

    显示为我创建新连接选项的屏幕截图。

  5. 如果要手动创建连接或配置自己的 HTTP 源而不使用示例,请选择 “新建连接 ”并提供以下详细信息:

    • 基 URL:HTTP 终结点的基 URL。 信息将发送到指定的 URL。 确保信任输入的 URL。
    • 令牌受众 URI:令牌的目标资源,例如用于连接到 Azure 密钥保管库终结点。
    • 连接名称:输入此连接的名称
    • 身份验证类型:选择Anonymous、、BasicAPI KeyOrganizational account或。Service principal

    显示新连接页的屏幕截图。

  6. 请求方法:选择 GETPOST

  7. 标头和参数:根据需要进行配置。

  8. 请求间隔(s):指定在连续请求之间等待的时间(以秒为单位);有效范围为 [1, 3600]。

  9. 可以展开 “高级设置” 以访问 HTTP 源的更多配置选项:

    • 最大重试次数:发生错误时连接器重试请求的最大次数;有效范围为 [10, 100]。
    • 重试退避(s):发生错误后,连接器在重试之前的等待时间(秒);有效范围 [1, 3600]。
    • 重试状态代码:返回的 HTTP 错误代码会提示连接器重试请求。 输入逗号分隔的代码列表或代码范围。 使用开始代码和可选结束代码指定范围。 例如:
      • 400 - 包括所有大于或等于 400 的代码
      • 400-500 包括从 400 到 500 的所有代码,其中包含代码500。
      • 404,408,500 - 提示连接器重试 404 NOT FOUND、408 请求超时和所有 5xx 错误代码。 有些状态码始终会被重试,例如未经授权、超时和请求过多。
  10. 可以通过在“流详细信息”部分选择源名称铅笔图标来编辑 HTTP 源名称。 然后选择下一步

    显示配置的设置的屏幕截图。

  11. “查看 + 连接 ”页上,查看 HTTP 源的配置摘要,然后选择“ 添加” 以完成设置。

    显示“审阅配置”页的屏幕截图。

可以在 “编辑”模式下看到添加到事件流的 HTTP 源。

“编辑”模式下添加的 HTTP 源的屏幕截图,其中突出显示了“发布”按钮。

选择 “发布” 来发布更改,开始将数据从 HTTP 源传输到事件流。

实时视图中添加的 HTTP 源的屏幕截图,其中突出显示了“发布”按钮。

限度

  • HTTP 源当前不支持 CI/CD 功能,包括 Git 集成部署管道。 尝试将具有此源的事件流项导出或导入 Git 存储库可能会导致错误。

其他连接器: