#azure-logic-apps
Вопрос:
У меня есть приложение Azure Logic, и я хочу, чтобы оно получало JSON из общедоступного API и выполняло некоторые простые преобразования в JSON. API находится на https://api.wazirx.com/api/v2/trades?market=btcusdt (это для получения данных о торговле биткойнами).
В настоящее время у меня есть действия рабочего процесса, приведенные ниже. Я использую шаг действия Compose, чтобы изменить JSON из исходного ответа API. Я хочу изменить несколько имен свойств из ответа, а также удалить одно из свойств из JSON. Какой хороший метод для достижения такого простого сопоставления? Вложенная замена, которую я в настоящее время использую для переименования свойств, явно неуклюжа, и я не уверен, как удалить одно из свойств:
"actions": {
"HTTP": {
"inputs": {
"headers": {
"X-API-Key": "..."
},
"method": "GET",
"queries": {
},
"uri": "https://api.wazirx.com/api/v2/trades?market=btcusdt"
},
"runAfter": {},
"type": "Http"
},
"Compose": {
"inputs": "@json(replace(replace(replace(string(body('HTTP')),'"btcusdt"','"BitcoinUsdt"'), '"volume"', '"BitcoinAmount"'), '"funds"','"UsdtAmount"'))",
"runAfter": {
"HTTP": [
"Succeeded"
]
},
"type": "Compose"
},
Образец исходного JSON из API доступен по адресу https://api.wazirx.com/api/v2/trades?market=btcusdt . Вот пример данных:
[{"id":240144546,"market":"btcusdt","price":"62800.0","volume":"0.00022","funds":"13.816","created_at":"2021-10-26T02:39:07Z","side":null},{"id":240144420,"market":"btcusdt","price":"62800.0","volume":"0.0003","funds":"18.84","created_at":"2021-10-26T02:39:03Z","side":null}]
Я хочу удалить «идентификатор» и его значение и переименовать некоторые свойства в соответствии с replace в моем текущем коде рабочего процесса). Результат, который мне нужен, выглядит следующим образом:
[{"market":"BitcoinUsdt","price":"62800.0","BitcoinAmount":"0.00022","UsdtAmount":"13.816","created_at":"2021-10-26T02:39:07Z","side":null},{"id":240144420,"market":"btcusdt","price":"62800.0","volume":"0.0003","funds":"18.84","created_at":"2021-10-26T02:39:03Z","side":null}]
Какой хороший и простой способ добиться этого преобразования? Я пытался создавать и, Parse_JSON действия с For_each , но, похоже, я действительно ищу что-то вроде жидких шаблонов. Это самый простой способ или есть что-то подобное, что я могу использовать непосредственно в приложениях Azure Logic, вместо того, чтобы загружать шаблон liquid в мою учетную запись интеграции Azure для выполнения преобразования?
Комментарии:
1. Вы можете использовать
composeconnector и добавить необходимые сведения в формате JSON и соответственно использовать то же значение. Вот скриншот для лучшего объяснения. i.imgur.com/2zdigJ1.png
Ответ №1:
Это то, что будет работать. 
На шаге инициализации переменной я инициализировал переменную массива с именем finalresult с начальным значением [] . При этом будет сохранен конечный массив результатов JSON. 
В моем для каждого шага я сначала анализирую каждый вывод для извлечения отдельных атрибутов. Затем я составляю результат, используя атрибуты и переименовывая некоторые свойства. Ниже приведено то, что я использую в качестве входных данных.
{
"BitcoinAmount": @{body('Parse_JSON')?['volume']},
"UsdtAmount": @{body('Parse_JSON')?['funds']},
"created_at": @{body('Parse_JSON')?['created_at']},
"market": @{body('Parse_JSON')?['market']},
"price": @{body('Parse_JSON')?['price']},
"side": @{body('Parse_JSON')?['side']}
}
Наконец, я добавляю результат в свою переменную массива finalresult.
После for each я отвечаю на свой вызов API своим ответом finalresult.
Мой полный код логического приложения приведен ниже.
{
"definition": {
"$schema": "https://schema.management.azure.com/providers/Microsoft.Logic/schemas/2016-06-01/workflowdefinition.json#",
"actions": {
"For_each": {
"actions": {
"Append_to_array_variable": {
"inputs": {
"name": "finalresult",
"value": "@outputs('Compose')"
},
"runAfter": {
"Compose": [
"Succeeded"
]
},
"type": "AppendToArrayVariable"
},
"Compose": {
"inputs": {
"BitcoinAmount": "@body('Parse_JSON')?['volume']",
"UsdtAmount": "@body('Parse_JSON')?['funds']",
"created_at": "@body('Parse_JSON')?['created_at']",
"market": "@body('Parse_JSON')?['market']",
"price": "@body('Parse_JSON')?['price']",
"side": "@body('Parse_JSON')?['side']"
},
"runAfter": {
"Parse_JSON": [
"Succeeded"
]
},
"type": "Compose"
},
"Parse_JSON": {
"inputs": {
"content": "@items('For_each')",
"schema": {
"properties": {
"created_at": {
"type": "string"
},
"funds": {
"type": "string"
},
"id": {
"type": "integer"
},
"market": {
"type": "string"
},
"price": {
"type": "string"
},
"side": {},
"volume": {
"type": "string"
}
},
"type": "object"
}
},
"runAfter": {},
"type": "ParseJson"
}
},
"foreach": "@body('HTTP')",
"runAfter": {
"Initialize_variable": [
"Succeeded"
]
},
"type": "Foreach"
},
"HTTP": {
"inputs": {
"method": "GET",
"uri": "https://api.wazirx.com/api/v2/trades?market=btcusdt"
},
"runAfter": {},
"type": "Http"
},
"Initialize_variable": {
"inputs": {
"variables": [
{
"name": "finalresult",
"type": "array",
"value": []
}
]
},
"runAfter": {
"HTTP": [
"Succeeded"
]
},
"type": "InitializeVariable"
},
"Response": {
"inputs": {
"body": "@variables('finalresult')",
"statusCode": 200
},
"kind": "http",
"runAfter": {
"For_each": [
"Succeeded"
]
},
"type": "Response"
}
},
"contentVersion": "1.0.0.0",
"outputs": {},
"parameters": {},
"triggers": {
"manual": {
"inputs": {
"schema": {}
},
"kind": "Http",
"type": "Request"
}
}
},
"parameters": {}
}
Комментарии:
1. Если это отвечает на ваш вопрос, пожалуйста, отметьте это как ответ, чтобы этот вопрос можно было закрыть.
