使用功能应用将消息从Azure Service Bus中的APIM发送到API

Question

有没有办法发送在服务总线队列上接收到的有效载荷，使用功能应用程序将其发送到API中的API？我计划在ServiceBustrigger函数上执行此操作。我已经在Queuemessage上有消息/有效载荷，我只需要直接调用API并将Queuemessage的值发送到API

public static void Run([ServiceBusTrigger("sbq-messagequery", Connection = "ServiceBusConnection")]
    QueueMessage queueItem, ILogger log)
    {
        dynamic data = JsonConvert.SerializeObject(queueItem);
        log.LogInformation($"C# ServiceBus queue trigger function processed message: {data}");
        log.LogWarning($"Id = {queueItem.Payload}");
    }

Answer 1

您必须在触发方法中进行httprequest。

请找到建议在Azure函数中使用httpclient

        [FunctionName("MyHttpTrigger")]
    public async Task<IActionResult> Run(
        [HttpTrigger(AuthorizationLevel.Function, "get", "post", Route = null)] HttpRequest req,
        ILogger log)
    {
        var response = await _client.GetAsync("https://microsoft.com");
        var message = _service.GetMessage();

        return new OkObjectResult("Response from function with injected dependencies.");
    }

在您的情况下，这可能是邮政请求：

public static void Run([ServiceBusTrigger("sbq-messagequery", Connection = "ServiceBusConnection")] QueueMessage queueItem, ILogger log)
{
    dynamic data = JsonConvert.SerializeObject(queueItem);
    log.LogInformation($"C# ServiceBus queue trigger function processed message: {data}");
    log.LogWarning($"Id = {queueItem.Payload}");

    var requestMessage = new HttpRequestMessage(HttpMethod.Post, "https://yourtarget/api/lorem");
    var json = JsonConvert.SerializeObject(queueItem.Payload);
    requestMessage.Content = new StringContent(json, Encoding.UTF8, "application/json");
    var response = _client.SendAsync(httpRequestMessage).Result;
}