Запросы к API Gmail должны быть авторизованы с использованием учетных данных OAuth 2.0. Вам следует использовать поток на стороне сервера, когда вашему приложению требуется доступ к API Google от имени пользователя, например, когда пользователь находится в автономном режиме. Этот подход требует передачи одноразового кода авторизации от вашего клиента на ваш сервер; этот код используется для получения токена доступа и токена обновления вашего сервера.
Дополнительные сведения о реализации Google OAuth 2.0 на стороне сервера см. в разделе Использование OAuth 2.0 для приложений веб-сервера .
Содержание
Создайте идентификатор клиента и секрет клиента.
Чтобы начать использовать Gmail API, вам необходимо сначала использовать инструмент настройки , который поможет вам создать проект в консоли Google API, включить API и создать учетные данные.
- На странице «Учетные данные» нажмите «Создать учетные данные» > «Идентификатор клиента OAuth» , чтобы создать учетные данные OAuth 2.0, или «Создать учетные данные» > «Ключ учетной записи службы» , чтобы создать учетную запись службы.
- Если вы создали идентификатор клиента OAuth, выберите тип приложения.
- Заполните форму и нажмите «Создать» .
Идентификаторы клиента вашего приложения и ключи учетной записи службы теперь указаны на странице «Учетные данные». Для получения подробной информации щелкните идентификатор клиента; параметры различаются в зависимости от типа идентификатора, но могут включать адрес электронной почты, секрет клиента, происхождение JavaScript или URI перенаправления.
Запишите идентификатор клиента, так как вам нужно будет добавить его в свой код позже.
Обработка запросов на авторизацию
Когда пользователь впервые загружает ваше приложение, ему открывается диалоговое окно, позволяющее предоставить вашему приложению разрешение на доступ к его учетной записи Gmail с запрошенными объемами разрешений . После этой первоначальной авторизации пользователю отображается диалоговое окно разрешений только в том случае, если изменяется идентификатор клиента вашего приложения или запрошенные области действия.
Аутентификация пользователя
В случае успеха этот первоначальный вход возвращает объект результата авторизации, который содержит код авторизации .
Обмен кода авторизации на токен доступа
Код авторизации — это одноразовый код, который ваш сервер может обменять на токен доступа . Этот токен доступа передается в API Gmail, чтобы предоставить вашему приложению доступ к пользовательским данным на ограниченный период времени.
Если вашему приложению требуется offline доступ, при первом обмене кодом авторизации ваше приложение также получает токен обновления , который используется для получения нового токена доступа после истечения срока действия предыдущего токена. Ваше приложение сохраняет этот токен обновления (обычно в базе данных на вашем сервере) для последующего использования.
В следующих примерах кода демонстрируется обмен кода авторизации на токен доступа при offline доступе и сохранение токена обновления.
Питон
Замените значение CLIENTSECRETS_LOCATION расположением вашего файла client_secrets.json .
import logging
from oauth2client.client import flow_from_clientsecrets
from oauth2client.client import FlowExchangeError
from apiclient.discovery import build
# ...
# Path to client_secrets.json which should contain a JSON document such as:
# {
# "web": {
# "client_id": "[[YOUR_CLIENT_ID]]",
# "client_secret": "[[YOUR_CLIENT_SECRET]]",
# "redirect_uris": [],
# "auth_uri": "https://accounts.google.com/o/oauth2/auth",
# "token_uri": "https://accounts.google.com/o/oauth2/token"
# }
# }
CLIENTSECRETS_LOCATION = '<PATH/TO/CLIENT_SECRETS.JSON>'
REDIRECT_URI = '<YOUR_REGISTERED_REDIRECT_URI>'
SCOPES = [
'https://www.googleapis.com/auth/gmail.readonly',
'https://www.googleapis.com/auth/userinfo.email',
'https://www.googleapis.com/auth/userinfo.profile',
# Add other requested scopes.
]
class GetCredentialsException(Exception):
"""Error raised when an error occurred while retrieving credentials.
Attributes:
authorization_url: Authorization URL to redirect the user to in order to
request offline access.
"""
def __init__(self, authorization_url):
"""Construct a GetCredentialsException."""
self.authorization_url = authorization_url
class CodeExchangeException(GetCredentialsException):
"""Error raised when a code exchange has failed."""
class NoRefreshTokenException(GetCredentialsException):
"""Error raised when no refresh token has been found."""
class NoUserIdException(Exception):
"""Error raised when no user ID could be retrieved."""
def get_stored_credentials(user_id):
"""Retrieved stored credentials for the provided user ID.
Args:
user_id: User's ID.
Returns:
Stored oauth2client.client.OAuth2Credentials if found, None otherwise.
Raises:
NotImplemented: This function has not been implemented.
"""
# TODO: Implement this function to work with your database.
# To instantiate an OAuth2Credentials instance from a Json
# representation, use the oauth2client.client.Credentials.new_from_json
# class method.
raise NotImplementedError()
def store_credentials(user_id, credentials):
"""Store OAuth 2.0 credentials in the application's database.
This function stores the provided OAuth 2.0 credentials using the user ID as
key.
Args:
user_id: User's ID.
credentials: OAuth 2.0 credentials to store.
Raises:
NotImplemented: This function has not been implemented.
"""
# TODO: Implement this function to work with your database.
# To retrieve a Json representation of the credentials instance, call the
# credentials.to_json() method.
raise NotImplementedError()
def exchange_code(authorization_code):
"""Exchange an authorization code for OAuth 2.0 credentials.
Args:
authorization_code: Authorization code to exchange for OAuth 2.0
credentials.
Returns:
oauth2client.client.OAuth2Credentials instance.
Raises:
CodeExchangeException: an error occurred.
"""
flow = flow_from_clientsecrets(CLIENTSECRETS_LOCATION, ' '.join(SCOPES))
flow.redirect_uri = REDIRECT_URI
try:
credentials = flow.step2_exchange(authorization_code)
return credentials
except FlowExchangeError, error:
logging.error('An error occurred: %s', error)
raise CodeExchangeException(None)
def get_user_info(credentials):
"""Send a request to the UserInfo API to retrieve the user's information.
Args:
credentials: oauth2client.client.OAuth2Credentials instance to authorize the
request.
Returns:
User information as a dict.
"""
user_info_service = build(
serviceName='oauth2', version='v2',
http=credentials.authorize(httplib2.Http()))
user_info = None
try:
user_info = user_info_service.userinfo().get().execute()
except errors.HttpError, e:
logging.error('An error occurred: %s', e)
if user_info and user_info.get('id'):
return user_info
else:
raise NoUserIdException()
def get_authorization_url(email_address, state):
"""Retrieve the authorization URL.
Args:
email_address: User's e-mail address.
state: State for the authorization URL.
Returns:
Authorization URL to redirect the user to.
"""
flow = flow_from_clientsecrets(CLIENTSECRETS_LOCATION, ' '.join(SCOPES))
flow.params['access_type'] = 'offline'
flow.params['approval_prompt'] = 'force'
flow.params['user_id'] = email_address
flow.params['state'] = state
return flow.step1_get_authorize_url(REDIRECT_URI)
def get_credentials(authorization_code, state):
"""Retrieve credentials using the provided authorization code.
This function exchanges the authorization code for an access token and queries
the UserInfo API to retrieve the user's e-mail address.
If a refresh token has been retrieved along with an access token, it is stored
in the application database using the user's e-mail address as key.
If no refresh token has been retrieved, the function checks in the application
database for one and returns it if found or raises a NoRefreshTokenException
with the authorization URL to redirect the user to.
Args:
authorization_code: Authorization code to use to retrieve an access token.
state: State to set to the authorization URL in case of error.
Returns:
oauth2client.client.OAuth2Credentials instance containing an access and
refresh token.
Raises:
CodeExchangeError: Could not exchange the authorization code.
NoRefreshTokenException: No refresh token could be retrieved from the
available sources.
"""
email_address = ''
try:
credentials = exchange_code(authorization_code)
user_info = get_user_info(credentials)
email_address = user_info.get('email')
user_id = user_info.get('id')
if credentials.refresh_token is not None:
store_credentials(user_id, credentials)
return credentials
else:
credentials = get_stored_credentials(user_id)
if credentials and credentials.refresh_token is not None:
return credentials
except CodeExchangeException, error:
logging.error('An error occurred during code exchange.')
# Drive apps should try to retrieve the user and credentials for the current
# session.
# If none is available, redirect the user to the authorization URL.
error.authorization_url = get_authorization_url(email_address, state)
raise error
except NoUserIdException:
logging.error('No user ID could be retrieved.')
# No refresh token has been retrieved.
authorization_url = get_authorization_url(email_address, state)
raise NoRefreshTokenException(authorization_url)
Авторизация с использованием сохраненных учетных данных
Когда пользователи посещают ваше приложение после успешной первой авторизации, ваше приложение может использовать сохраненный токен обновления для авторизации запросов без повторного запроса пользователя.
Если вы уже аутентифицировали пользователя, ваше приложение может получить токен обновления из своей базы данных и сохранить его в сеансе на стороне сервера. Если токен обновления отозван или является недействительным по какой-либо причине, вам необходимо отследить это и принять соответствующие меры.
Использование учетных данных OAuth 2.0
После получения учетных данных OAuth 2.0, как показано в предыдущем разделе, их можно использовать для авторизации объекта службы Gmail и отправки запросов к API.
Создать экземпляр объекта службы
В этом примере кода показано, как создать экземпляр объекта службы, а затем разрешить ему выполнять запросы API.
Питон
from apiclient.discovery import build
# ...
def build_service(credentials):
"""Build a Gmail service object.
Args:
credentials: OAuth 2.0 credentials.
Returns:
Gmail service object.
"""
http = httplib2.Http()
http = credentials.authorize(http)
return build('gmail', 'v1', http=http)
Отправляйте авторизованные запросы и проверяйте наличие отозванных учетных данных.
В следующем фрагменте кода используется авторизованный экземпляр службы Gmail для получения списка сообщений.
В случае возникновения ошибки код проверяет код состояния HTTP 401 , который следует обрабатывать путем перенаправления пользователя на URL-адрес авторизации.
Дополнительные операции API Gmail описаны в Справочнике по API .
Питон
from apiclient import errors
# ...
def ListMessages(service, user, query=''):
"""Gets a list of messages.
Args:
service: Authorized Gmail API service instance.
user: The email address of the account.
query: String used to filter messages returned.
Eg.- 'label:UNREAD' for unread Messages only.
Returns:
List of messages that match the criteria of the query. Note that the
returned list contains Message IDs, you must use get with the
appropriate id to get the details of a Message.
"""
try:
response = service.users().messages().list(userId=user, q=query).execute()
messages = response['messages']
while 'nextPageToken' in response:
page_token = response['nextPageToken']
response = service.users().messages().list(userId=user, q=query,
pageToken=page_token).execute()
messages.extend(response['messages'])
return messages
except errors.HttpError, error:
print 'An error occurred: %s' % error
if error.resp.status == 401:
# Credentials have been revoked.
# TODO: Redirect the user to the authorization URL.
raise NotImplementedError()
Следующие шаги
Как только вы освоитесь с авторизацией запросов Gmail API, вы будете готовы приступить к обработке сообщений, цепочек и меток, как описано в разделах «Руководства для разработчиков».
Подробнее о доступных методах API можно узнать в Справочнике API .