使用Java Azure函数SDK处理二进制数据

Question

我想使用Java Azure Functions SDK来：

1. 接受PDF作为输入
2. 处理PDF（使用pdfbox库）。
3. 返回更改的PDF。

最终结果应该从队列中读取PDF，并将处理后的PDF发布到另一个队列。

是否有使用JavaAzure Functions SDK从队列读取/写入二进制数据的示例？

对于测试、调试和其他用途，最好有：

>

通过post接受PDF的超文本传输协议触发器。如何在Java做到这一点？目前还不清楚如何在超文本传输协议触发器中使用HttquiestMessage。

1.1. 我可以在Http触发器中使用零参数或可选参数吗？

1.2.解析参数自己使用Http刚需消息？

您可以使用Http响应消息作为返回类型并设置返回代码。不清楚如何将mime类型的输出设置为应用程序/pdf。

我第一次尝试将有效的html作为字符串返回，但返回并呈现为纯文本。

原因是，使用触发器时，不必设置队列。

Answer 1

根据您的需要，我的建议可分为以下几个步骤：

在HttpTrigger Azure函数中使用Azure存储队列Java sdk。

步骤1：从队列接收二进制数据。

   // Setup the cloud storage account.
   CloudStorageAccount account = CloudStorageAccount.parse(storageConnectionString);

   // Create a queue service client
   CloudQueueClient queueClient = account.createCloudQueueClient();

   // Retrieve a reference to a queue
   // Append a random UUID to the end of the queue name so that this

   // sample can be run more than once in quick succession.
   CloudQueue queue = queueClient.getQueueReference("test");

  // Retrieve the first visible message in the queue
    CloudQueueMessage retrieveMessage = queue.retrieveMessage();

第2步：使用pdfbox库来处理pdf文件。

第三步：将二进制数据发送到队列中。

    // Setup the cloud storage account.
    CloudStorageAccount account = CloudStorageAccount.parse(storageConnectionString);

   // Create a queue service client
   CloudQueueClient queueClient = account.createCloudQueueClient();

   // Retrieve a reference to a queue
   // Append a random UUID to the end of the queue name so that this

   // sample can be run more than once in quick succession.
   CloudQueue queue = queueClient.getQueueReference("test");

   // Create messages and add it to the queue
   CloudQueueMessage message1 = new CloudQueueMessage("your pdf data");
                queue.addMessage(message1);

配置HttpTrigger Azure函数的输入和输出。

当然，Azure函数支持零或可选参数。

步骤4：关于配置输入和输出参数，有两种方法：

1.注释

public class Function {
    public String echo(@HttpTrigger(name = "req", methods = {"post"},  authLevel = AuthorizationLevel.ANONYMOUS) 
        String req, ExecutionContext context) {
        return String.format(req);
    }
}

2.功能。json

{
  "scriptFile": "azure-functions-example.jar",
  "entryPoint": "com.example.MyClass.echo",
  "bindings": [
    {
      "type": "httpTrigger",
      "name": "req",
      "direction": "in",
      "authLevel": "anonymous",
      "methods": [ "post" ]
    },
    {
      "type": "http",
      "name": "$return",
      "direction": "out"
    }
  ]
}

你可以从这里得到细节。

希望对你有帮助。