使用 PHP 为 Google Cloud Storage 创建 Pub/Sub 通知

Question

所以，我有一个基于 GKE 的函数来处理图像文件。我希望每当使用 Pub/Sub 将新文件转储到存储桶中时触发此功能。我有一个将图像文件推送到存储桶中的外部系统。我使用对象通知来执行此操作，现在我想使用 Pub/Sub。

我能否在 GoogleCloudStorage 中创建一个通知，以生成我的处理函数将要提取的 Pub/Sub 通知？我正在查看 PHP 库 (https://googleapis.github.io/google-cloud-php/#/docs/google-cloud/v0.162.0/storage/notification) 来执行此操作，但文档非常不足。

这段代码创建了一个通知，但我应该提供一个通知 ID 似乎很奇怪，而且我不确定有效负载将是什么......

$client=new StorageClient(['projectId'=><my project>, 'keyFile'=><key file contents>]);

$bucket_name = <my bucket name>;
$notification_id = '2482';  // ?????

$notification_params = [
        'eventType'     => 'OBJECT_FINALIZE',
        'payloadFormat' => 'JSON_API_V1',
        'bucketId'      => $bucket_name,
];

$bucket = $client->bucket( $bucket_name );

$notification = $bucket->notification( $notification_id );

这是创建我想要的通知的正确方法吗？我是否以这种方式指定我自己的 id？如果发生碰撞会怎样？

谢谢， 安迪

Answer 1

是的，可以在将对象推送到存储桶时创建 Pub/Sub 通知。在创建通知之前，您需要先create a Pub/Sub topic and subscriber。

我使用了sample code create pub/sub notification，只是添加了存储桶的定义：

use Google\Cloud\Core\Iam\PolicyBuilder;
use Google\Cloud\PubSub\PubSubClient;
use Google\Cloud\Storage\StorageClient;


$storage = new StorageClient();
$bucket = $storage->bucket('your-bucket'); // define bucket to be used

$pubSub = new PubSubClient();
$topicName = 'your-topic'; // define the topic to be used

// grant pubsub publisher role for topic
$serviceAccountEmail = $storage->getServiceAccount();
$topic = $pubSub->topic($topicName);
$iam = $topic->iam();
$updatedPolicy = (new PolicyBuilder($iam->policy()))
    ->addBinding('roles/pubsub.publisher', [
        "serviceAccount:$serviceAccountEmail"
    ])
    ->result();
$iam->setPolicy($updatedPolicy);

$notification = $bucket->createNotification($topicName, [
    'event_types' => [
        'OBJECT_DELETE',
        'OBJECT_METADATA_UPDATE'
    ]
]);

要对此进行测试，请在创建发布/订阅通知时：

• 将对象推送到您的存储桶中
• 主题应该向订阅者发送消息
• 检查订阅者中的消息

---

在测试桶中推送对象：

---

向订阅者发布消息/通知：