Как использовать Deferred.defer с Oauth2 в приложении Google App?
-
21-12-2019 - |
Вопрос
У меня есть декоратор:
http = httplib2.Http()
service = discovery.build('gmail', 'v1', http=http)
# Creating decorator for OAuth2 account.
decorator = appengine.oauth2decorator_from_clientsecrets(
CLIENT_SECRETS,
scope='https://www.googleapis.com/auth/gmail.readonly',
message=MISSING_CLIENT_SECRETS_MESSAGE)
.
и класс, который его использует:
class CSVGeneratorHandler(webapp2.RedirectHandler):
@decorator.oauth_required
def get(self):
http = decorator.http()
first_messages = service.users().messages().list(userId='me').execute(http=http)
template = JINJA_ENVIRONMENT.get_template('templates/success.html')
self.response.write(template.render({}))
.
Это отлично работает.
Но когда я пытаюсь переместить запрос API Service.users (). Сообщения (). Список (user= 'me'). Выполнить (http= http) к задаче (с отложенным.Отложите (get_mails))) Я получил ошибку: «Требуется логин».
Я понимаю, что функция get_mails должна принимать контекст или / и учетные данные из основной программы.Но я не понимаю, как это сделать.
Может кто-нибудь помочь мне?
Решение
Через несколько часов я нашел ответ.
Прежде всего, вам нужно сохранить учетные данные в какое-то место.Потому что мы, у нас, у нас есть особый тип поля для него:
from oauth2client.appengine import StorageByKeyName
from google.appengine.ext import db
class CredentialsModel(db.Model):
credentials = CredentialsProperty()
.
Следующий шаг - настроить Auth без декоратора, и только после этого отправить задачу в очередь:
user = users.get_current_user()
flow = flow_from_clientsecrets(os.path.join(os.path.dirname(os.path.realpath(__file__)), CLIENT_SECRETS),
scope='https://www.googleapis.com/auth/gmail.readonly',
redirect_uri='http://127.0.0.1:8080/success')
auth_uri = str(flow.step1_get_authorize_url())
code = self.request.get('code')
if not code:
return self.redirect(auth_uri)
credentials = flow.step2_exchange(code)
storage = StorageByKeyName(CredentialsModel, user.user_id(), 'credentials')
storage.put(credentials)
deferred.defer(get_mails, user.user_id())
.
Не забывайте о получении учетных данных в отложенной функции!
def get_mails(user_id):
storage = StorageByKeyName(CredentialsModel, user_id, 'credentials')
credentials = storage.get()
http = httplib2.Http()
http = credentials.authorize(http)
all_messages = []
service = discovery.build('gmail', 'v1', http=http)
first_messages = service.users().messages().list(userId='me').execute()
.