我正在尝试将以下请求Map到SQL数据库https://api.exchangerate.host/timeseries?start_date=2023-01-01&end_date=2023-01-10&base=USD&symbols=MXN&format=json
问题是,日期是不断变化的,我需要以某种方式Map他们与某种通配符。我不能使用这种特殊情况下的数据流。
最后,我需要两个具有预定义整数的自定义列,即日期和汇率值
我正在尝试将以下请求Map到SQL数据库https://api.exchangerate.host/timeseries?start_date=2023-01-01&end_date=2023-01-10&base=USD&symbols=MXN&format=json
问题是,日期是不断变化的,我需要以某种方式Map他们与某种通配符。我不能使用这种特殊情况下的数据流。
最后,我需要两个具有预定义整数的自定义列,即日期和汇率值
1条答案
按热度按时间lawou6xi1#
最后,我需要两个具有预定义整数的自定义列,即日期和汇率值
通过使用您的请求,我能够使用split和for循环以及
openjson()
来完成您的需求。问题是,日期是不断变化的,我需要以某种方式Map他们与某种通配符
由于日期是变化的,你不能动态地访问这些值。为了动态地获取它,首先我在一个web活动中接受了你的请求,并在
rates
对象的字符串上使用了一个拆分,其中包含':{"MXN":'
和以下动态内容。@split(string(activity('Web1').output.rates),':{"MXN":')
我把这个数组存储在一个数组变量中。
然后,我通过跳过最后一个值将这个数组传递给ForEach,并在下面的动态内容中。
@take(variables('split_arr'),sub(length(variables('split_arr')),1))
我使用这个ForEach来构建一个JSON数组,其中每个索引中的对象都是date和rate。为此,我在forEach中使用了一个追加变量activity到
json_arr
数组变量,其中包含以下动态内容。它将给予如下所示的JSON数组。
使用这个JSON数组和SQL作为源来复制活动,并在查询中使用
openjson()
,如下所示。在复制活动的接收器中,根据您的要求给予您的接收器。在这里,我使用了一个SQL表。
以下是我的pipeline JSON,供大家参考:
结果: