Auto skalowanie Kolejka ciągnąć w App Engine

Question

próbuję wdrożyć system powiadomień push w PHP, który musi wysłać masywne powiadomienia z możliwie najkrótszym czasie, jak described here:

Wadą I zobacz w tej architekturze, jak automatycznie skalować pracowników powiadomień. O ile mi wiadomo, nie ma sposobu, aby policzyć oczekujące zadania w kolejce do wyciągania, ani liczyć aktywnych pracowników. Jak byś to zrobił?

Answer 1

Rozwiązałem to liczenie zadań oczekujących w kolejce powiadomień z tej metody, a następnie dodanie pracowników w zależności od liczby oczekujących zadań:

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(); 
    } 

Answer 2

Istnieją statystyki kolejek, w których można uzyskać liczbę zadań w kolejce https://cloud.google.com/appengine/docs/python/refdocs/google.appengine.api.taskqueue. Używamy go do monitorowania liczby zadań, wydaje się, że można go wykorzystać do swojego celu.