Azure功能中的MediaTr命令ServiceBustrigger

发布于 2025-01-23 18:51:34 字数 962 浏览 4 评论 0 原文

使用一些引用，我使用干净的体系结构创建了 azure函数应用程序，项目结构看起来像这样：

“ nofollow noreferrer”> “在此处。基本上，我想调用 MediaTr 命令 createProductCommand 此功能触发器内。因此，只要有消息将消息推入服务总线队列时，我就可以使用此 MediaTr 命令将其保存到SQL数据库中。 createProductCommand 具有EF核心实现。

public class SaveProductDataToDatabase
    {
        private readonly IMediator _mediator;

        public SaveProductDataToDatabase(IMediator mediator)
        {
            _mediator = mediator;
        }

        [FunctionName("SaveProductDataToDatabase")]
        public void Run([ServiceBusTrigger("product-data-dev-01", Connection = "ServiceBusConnectionString")] string myQueueItem, ILogger log)
        {
            log.LogInformation($"Processed message: {myQueueItem}");
        }
    }

我不确定如何在此功能触发器内使用 createProductCommand 。请帮忙。

原文

Using some references, I have created the Azure Function App with Clean Architecture and the Project structure looks like this:

My Azure Function is of the type Service Bus Queue Trigger. Basically, I want to Call MediatR command CreateProductCommand inside this function trigger. So that, whenever there is a message pushed into Service bus Queue, I can read that and save that into SQL database using this MediatR command. CreateProductCommand has EF Core implementation.

public class SaveProductDataToDatabase
    {
        private readonly IMediator _mediator;

        public SaveProductDataToDatabase(IMediator mediator)
        {
            _mediator = mediator;
        }

        [FunctionName("SaveProductDataToDatabase")]
        public void Run([ServiceBusTrigger("product-data-dev-01", Connection = "ServiceBusConnectionString")] string myQueueItem, ILogger log)
        {
            log.LogInformation(quot;Processed message: {myQueueItem}");
        }
    }

I'm not sure how to use the CreateProductCommand inside this function trigger. Please help.