Como fazer operações que requerem OAuth em uma fila de tarefas do GAE?
Eu tenho um aplicativo do Google App Engine simples que inclui um/update
página que atualiza uma lista de reprodução do YouTube. Se parece com isso:
class UpdatePage(webapp2.RequestHandler):
@decorator.oauth_required
def get(self):
update_result = self.update_playlist()
...
routes = [('/update', UpdatePage),
(decorator.callback_path, decorator.callback_handler())]
app = webapp2.WSGIApplication(routes, debug=True)
Funciona como esperado eupdate_playlist()
método faz o seu trabalho, mas verifica-se que em algumas circunstâncias, pode ser executado por um tempo muito longo, resultando em umDeadlineExceededError
. Então, depois de ler sobre as opções disponíveis, eu percebiFila de Tarefas API é o caminho a percorrer (certo?) E eu estou tentando usá-lo, seguindo oUsando filas push em Python guia.
→ Em resumo, eu dividiUpdatePage
para dentroUpdatePageHandler
+ UpdatePageWorker
:
class UpdateHandlerPage(webapp2.RequestHandler):
@decorator.oauth_required
def get(self):
taskqueue.add(url='/updateworker')
class UpdateWorkerPage(webapp2.RequestHandler):
def post(self):
update_result = self.update_playlist()
...
routes = [('/update', UpdateHandlerPage),
('/updateworker', UpdateWorkerPage),
(decorator.callback_path, decorator.callback_handler())]
app = webapp2.WSGIApplication(routes, debug=True)
Infelizmente, depois de fazer a divisão, parece que o meu decorador OAuth2 não faz mais o seu trabalho:
INFO 2013-05-30 17:08:53,971 discovery.py:709] URL being requested: https://www.googleapis.com/youtube/v3/playlists?alt=json&part=snippet%2Cstatus
WARNING 2013-05-30 17:08:53,975 urlfetch_stub.py:480] Stripped prohibited headers from URLFetch request: ['content-length']
INFO 2013-05-30 17:08:54,351 client.py:493] Refreshing due to a 401
INFO 2013-05-30 17:08:54,361 appengine.py:276] make: Got type <class 'google.appengine.api.datastore_types.Blob'>
INFO 2013-05-30 17:08:54,363 appengine.py:289] validate: Got type <class 'oauth2client.client.OAuth2Credentials'>
INFO 2013-05-30 17:08:54,364 client.py:680] Refreshing access_token
INFO 2013-05-30 17:08:54,746 client.py:699] Failed to retrieve access token: {
"error" : "invalid_grant"
}
INFO 2013-05-30 17:08:54,757 appengine.py:276] make: Got type <class 'google.appengine.api.datastore_types.Blob'>
INFO 2013-05-30 17:08:54,759 appengine.py:289] validate: Got type <class 'oauth2client.client.OAuth2Credentials'>
INFO 2013-05-30 17:08:54,761 appengine.py:289] validate: Got type <class 'oauth2client.client.OAuth2Credentials'>
INFO 2013-05-30 17:08:54,762 appengine.py:265] get: Got type <class 'oauth2client.appengine.CredentialsModel'>
E se em vez de decorarUpdateHandlerPage:get
Eu decoroUpdateWorkerPage:post
, Eu recebo um loop de falha infinito:
INFO 2013-05-30 17:24:31,307 discovery.py:190] URL being requested: https://www.googleapis.com/discovery/v1/apis/youtube/v3/rest?userIp=127.0.0.1
INFO 2013-05-30 17:24:34,960 dev_appserver.py:3105] "GET /update HTTP/1.1" 200 -
INFO 2013-05-30 17:24:35,060 dev_appserver.py:3105] "POST /updateworker HTTP/1.1" 302 -
WARNING 2013-05-30 17:24:35,065 taskqueue_stub.py:1980] Task task1 failed to execute. This task will retry in 0.100 seconds
INFO 2013-05-30 17:24:35,240 dev_appserver.py:3105] "POST /updateworker HTTP/1.1" 302 -
WARNING 2013-05-30 17:24:35,245 taskqueue_stub.py:1980] Task task1 failed to execute. This task will retry in 0.200 seconds
...
O que eu posso fazer? Obrigado pela ajuda!