单元测试Azure函数队列触发器

Question

我有一个Java项目，它使用了一些Azure函数，如HttpTrigger和QueueTrigger。我使用azure fucnations quickstart原型来生成这个项目，因此它可以使用HttpTrigger的一些样板代码和它的单元测试，但对QueueTrigger没有任何帮助。我正试图得到帮助，为这个QueueTrigger编写一个好的单元测试，它实际上是从队列中读取消息（弹出）。队列的代码如下所示：

@FunctionName("queuehandler")
    public void dequeue(
        @QueueTrigger(name="qmsg", queueName=QUEUE_NAME, connection=QUEUE_CONNECTION) String qmsg,  // this is the event message
        @BindingName("DequeueCount") int count,  // number of times this message has been popped off the stack.
        @BindingName("ExpirationTime") Date expireTime // time it will expire
    )
    {

        log.info("Queue Receive {} DequeueCount:{} Expires:{}", qmsg, count, expireTime);

        StopWatch stopWatch = new StopWatch();
        stopWatch.start();

        try
        {
            EventGridEvent event = convertStringMsgToEventJSON(qmsg);
            MyClass.getInstance().handle(event);
        }
        catch(Exception ex)
        {
            log.error("Error handling queue dequeue count: {}, expires: {}, qmessage", count, expireTime, qmsg, ex);
            // Throwing an exception will cause the queue to retry this message again.
            // as per host.json, every failed message is retried for maximum of 3 times with an interval of 3 minutes
            throw ex;
        }
        finally
        {
            sw.stop();
            log.info("time it took to handle queue message: {}", sw.toString());
        }
    }

有没有人能推荐一下这个队列触发azure函数的标准单元测试？例如，看起来Boierplate HttpTrigger测试只是传递一个带有参数“name”和“azure”以及空主体的请求，并调用一个< code>assertEquals来使请求的状态为< code>200或< code>ok。

Answer 1

如果 Azure Functions 在 Java 中支持 DI，这会更简单，但就目前情况而言，您可能想要做的是将函数的主体提取到接受 MyClass 实例的单独方法中。然后，您可以测试该方法而不是函数本身。测试时，传入 MyClass 的模拟并断言调用 handle（），在实际函数中只需使用 MyClass.getInstance（） 调用它。