Azure 数据工厂 Web API 事件

Question

我们正在使用 Azure 数据工厂从其中一个 API 获取天气数据。我们必须实现多个事件，首先我们需要一个包含所有纬度和经度数据的表，然后我们需要构建一个 Azure 管道来循环访问位置(坐标)并调用 API 来获取天气信息。以下是我执行的步骤。

1. 我正在使用查找事件从表中获取数据。
2. 然后我使用 Foreach 事件循环遍历纬度和经度。
3. 我正在使用设置变量事件，其中使用一个变量表示纬度，一个变量表示经度。
4. 我正在使用网络事件来传递 URL 并从 API 获取响应。

我能够实现大部分输出，但我遇到的问题是输出 URL 未获取任何数据，因为对于我的 URL 的某些部分， azure 的超链接已被删除并且无法读取。以下是屏幕截图。

1. 两个事件 Lookup 和 foreach 声明了四个变量

   

2. 我的源数据集是一个具有我想要的纬度和经度的 SQL 表。

   

3. 此事件显示两个设置变量以及 Web 和复制事件。

   

4. 我已添加变量的名称和值，这些变量将传递到 Web URL

   

5. 在下面的事件中我传递了天气 API 网址

   

6. 我传递 URL、键和纬度、经度变量、格式、天数的动态内容。

   

7. 如果您看到纬度值(即 41.4)之后的 URL 的超链接被删除，那么我将面临问题的最终输出，因此之后不会读取任何内容，并且数据不会以 JSON 格式传入。如何解决这个问题以及我们如何传递给 URL 中的变量，因为在我的例子中，纬度和经度是用逗号作为分隔符分隔的，如果我尝试添加逗号，它不会读取 URL

   

这是我尝试通过 Azure 数据工厂实现的最终 URL。

http://api.worldweatheronline.com/premium/v1/weather.ashx?key=*****************&q=41.14,80.68&format=JSON&num_of_days=5

Answer 1

查询的输出是什么。从 Weather_location 中选择纬度、经度？我认为那里的长值是-80，所以你遇到了问题。这是我尝试过的。

创建了两个变量 Long 和 lat 并设置您共享的值。使用以下表达式。

@concat('http://api.worldweatheronline.com/premium/v1/weather.ashx?key=XXXXXX&q=',variables('lat')
,',',variables('long'),'&format=JSON&num_of_days=5')

它工作得很好。

{
    "data": {
        "request": [
            {
                "type": "LatLon",
                "query": "Lat 41.14 and Lon 80.68"
            }
        ],
        "current_condition": [
            {
                "observation_time": "11:3

......

当你说超链接时，你是对的，它没有显示完整(请参见下面的屏幕截图)，但它仍然对我有用。

输入{"url": "http://api.worldweatheronline.com/premium/v1/weather.ashx?key=XXXXXX=41.14,80.68&format=JSON&num_of_days=5",“方法”:“获取”，“标题”:{}}

1/15 编辑

据我了解，目的是使用 API 并将响应 JSON 复制到 ADLE GEN 2 。

这就是我尝试时所做的。使用复制事件选择 SINK 作为 REST ，链接服务中的基本 URL 是 http://api.worldweatheronline.com .

创建一个新变量:relativeurl:

@concat('/premium/v1/weather.ashx?key=yourkey&q=',variables('lat')
,',',variables('long'),'&format=JSON&num_of_days=5')

我们将使用它作为 SOURCE 相对 url 中的参数。

转到复制事件 (CA) -> 源 DS -> 打开 -> 参数 -> 相对 URL

转到复制事件 ( CA ) -> 源 -> 您应该看到relativeurl ->@variables('relativeurl')

转到复制事件 (CA) -> 源 DS -> 打开 -> 相对 URL -@dataset().relativeurl

HTH