我正在尝试使用Azure数据工厂通过REST API从Pendo获取数据。此活动的 PYTHON 代码是
import requests
url = "https://app.pendo.io/api/v1/aggregation"
data = "{"response":{"mimeType":"application/json"},"request":{"pipeline":[{"source":{"guideEvents":null,"timeSeries":{"first":"1506977216000","count":-10,"period":"dayRange"}}}]}}"
headers = {
'x-pendo-integration-key': "[add_your_pendo_int_key_here]",
'content-type': "application/json"
}
response = requests.post(url, data = data, headers = headers)
如何通过 Azure 数据工厂定义代码的数据部分？ 我已经将内容类型和x-pendo-integration-key放在了额外的标题中。
问题解决了。PYTHON 代码的数据部分(不带(放在 Azure 数据工厂中复制活动的请求正文中，请求方法是 POST。
可以使用 HTTP连接器从 HTTP 终结点检索数据。以下活动支持此 HTTP 连接器：
- 具有支持的源/接收器矩阵的复制活动
- 查找活动 可以将数据从 HTTP 源复制到任何受支持的接收器数据存储。有关复制活动支持作为源和接收器的数据存储的列表，请参阅支持的数据存储和格式。
注意：若要在数据工厂中配置 HTTP 连接器之前测试用于数据检索的 HTTP 请求，请了解标头和正文要求的 API 规范。您可以使用邮递员或 Web 浏览器等工具进行验证。
https://learn.microsoft.com/en-us/azure/data-factory/connector-http
下面是开机自检的自定义活动示例：
{
"name": "HttpSourceDataInput",
"properties": {
"type": "HttpFile",
"linkedServiceName": {
"referenceName": "<HTTP linked service name>",
"type": "LinkedServiceReference"
},
"typeProperties": {
"relativeUrl": "<relative url>",
"requestMethod": "Post",
"requestBody": "<body for POST HTTP request>"
}
}
}
您可以在此处查看 ADF 相关示例。另请参阅此内容以供其他参考。 希望对您有所帮助。