google-app-engine - 在 App Engine 中自动缩放拉取队列

Question

我正在尝试在 PHP 中实现一个推送通知系统，该系统需要以尽可能短的延迟发送大量通知，如下所述：

我在这个架构中看到的缺点是如何自动扩展 Notification Workers。据我所知，没有办法计算拉队列中的待处理任务，也没有办法计算活动的工作人员。你会怎么做？

Answer 1

有队列统计信息，您可以在其中获取队列中的任务数https://cloud.google.com/appengine/docs/python/refdocs/google.appengine.api.taskqueue。我们用它来监控任务的数量，看来它可以用于您的目的。

Answer 2

我用这种方法解决了这个计算通知队列中的待处理任务的问题，然后根据待处理任务的数量添加工作人员：

public static function task_count($queue)
    {
        $request = new google\appengine\TaskQueueFetchQueueStatsRequest();
        $response = new  google\appengine\TaskQueueFetchQueueStatsResponse();

        $request->addQueueName($queue);            

        google\appengine\runtime\ApiProxy::makeSyncCall('taskqueue', 'FetchQueueStats', $request, $response);

        return $response->getQueueStats(0)->getNumTasks();
    }