将 JSON 负载发送到 Google Cloud Task

Question

我可能遗漏了一些非常明显的东西，但在我正在从事的项目中，我必须从信息的 CSV 发送许多工作以异步处理，而 Google App Engine 目前的方式是通过他们的新（测试版) Cloud Tasks 机制。

它将接受负载作为任务的一部分，因此我将发送一个 JSON 数组，其中包含每个作业的相关数据...除了指示 "Content-Type: application/json" 标头的唯一方法是在创建任务对象期间.

我正在使用 Google 自己的 cloud-tasks 0.5.0 库。

这是我一直在尝试的，因为这似乎是大多数其他非 cURL HTTP POST 请求接受 Content-Type 标头的方式...

require_once 'vendor/autoload.php';

use Google\Cloud\Tasks\V2beta3\AppEngineHttpQueue;
use Google\Cloud\Tasks\V2beta3\CloudTasksClient;
use Google\Cloud\Tasks\V2beta3\Queue;
use Google\Cloud\Tasks\V2beta3\Task;

<<< ...lots of cruft omitted... >>>

        $json_payload = json_encode(
            array(
                "batch" => $operation_time,
                "order" => $csvln[0],
                "customer" => $csvln[1],
                "email" => $csvln[2],
                "salesperson" => $csvln[3]
            )
        );

        //Create each of the tasks in the queue
        $options = [
            'http' => [
                'header'  => "Content-type: application/json",
                'method'  => 'POST',
                'content' => $json_payload
            ]
        ];

        $task = new Task($options);

任何帮助将不胜感激！

Answer 1

您可以使用来自Cloud Tasks PHP Client Library 的App Engine HTTP Request 将带有预定义负载的任务加载到任务队列中。

定义任务后，您可以使用AppEngineHttpRequest 提供给您的setter 方法来构造带有任何所需标头的HTTP 对象。这也将允许分配有效负载。

下面是一个简单的 sn-p，展示了如何将带有有效负载的任务附加到默认队列：

use Google\Cloud\Tasks\V2beta3\AppEngineHttpRequest;
use Google\Cloud\Tasks\V2beta3\HttpMethod;
use Google\Cloud\Tasks\V2beta3\Task;

//Preparing the payload
$json_payload = json_encode(
    array(
        "batch"       => date("h:i:sa"),
        "order"       => "Payload-0000",
        "customer"    => "Payload-0001",
        "email"       => "Payload-0002",
        "salesperson" => "Payload-0003"
    )
);

//Create and configure the task   
$httpR=new AppEngineHttpRequest();
$httpR->setBody($json_payload);
$httpR->setHeaders(['Content-type'=>'application/json']);
$httpR->setHttpMethod(HttpMethod::POST);   
$httpR->setRelativeUri("/example_task_handler");

$task = new Task();
$task->setAppEngineHttpRequest($httpR);

还可以考虑更新您的库，因为当前版本是 v0.86.0，即使在创建任务对象之后，它也允许分配标头。