Блог

В моем приложении logic я не вижу способа установить TTL или дату истечения срока действия сообщения очереди.

Но это возможно из пользовательского интерфейса, поэтому я знаю, что API может это сделать:

Я даже пытался «взломать» параметр строки запроса messagettl в представлении кода:

 "actions": {
    "Put_a_message_on_a_queue": {
        "inputs": {
            "body": "@{base64(items('For_each'))}",
            "host": {
                "connection": {
                    "name": "@parameters('$connections')['azurequeues']['connectionId']"
                }
            },
            "method": "post",
            "path": "/@{encodeURIComponent('updateuser')}/messages?messagettl=3600"
        },
        "runAfter": {},
        "type": "ApiConnection"
    }
}
  

Но я получаю сообщение об ошибке:

 {
 "message": "Unable to match incoming request to an operation."
}
  

Я понял это, просмотрев вызов API, выполненный в пользовательском интерфейсе добавления сообщений в очередь на портале Azure. Он добавляет параметр строки запроса messagettl , который равен секундам TTL.

Итак, я просмотрел схему здесь и обнаружил, что вы можете передать "queries": {...} объект в HTTP-вызов для добавления сообщения.

Окончательный вид кода в формате JSON:

 "actions": {
    "Put_a_message_on_a_queue": {
        "inputs": {
            "body": "@{base64(items('For_each'))}",
            "host": {
                "connection": {
                    "name": "@parameters('$connections')['azurequeues']['connectionId']"
                }
            },
            "method": "post",
            "path": "/@{encodeURIComponent('updateuser')}/messages",
            "queries": {
                "messagettl": 3600
            }
        },
        "runAfter": {},
        "type": "ApiConnection"
    }
}