{
  "partId": string,
  "mimeType": string,
  "filename": string,
  "headers": [
    {
      object (Header)
    }
  ],
  "body": {
    object (MessagePartBody)
  },
  "parts": [
    {
      object (MessagePart)
    }
  ]
}

{
  "partId": "1",
  "mimeType": "multipart/mixed",
  "filename": "",
  "headers": ...,
  "parts": [
    {
      "partId": "0.0",
      "mimeType": "text/plain",
      "filename": "",
      "headers": [
        {
          "name": "Content-Type",
          "value": "text/plain; charset=\"UTF-8\""
        }
      ],
      "body": {
        "size": 0
      }
    },...
    {
      "partId": "1",
      "mimeType": "application/x-zip-compressed",
      "filename": "tenpu-file.zip",
      "headers": ...,
      "body": {
        "attachmentId": "....",
        "size": 123456
      }
    },
    {
      "partId": "2",
      "mimeType": "image/png",
      "filename": "image.png",
      "headers": ...,
      "body": {
        "attachmentId": "....",
        "size": 123456
      }
    }
  ]
}

{
  "attachmentId": string,
  "size": integer,
  "data": string
}

import base64
from pathlib import Path

# 認証用の関数を新設しました。付録を参照してください。
from googleauth_util import get_cledential

from googleapiclient.discovery import build
from googleapiclient.errors import HttpError

SCOPES = ["https://www.googleapis.com/auth/gmail.readonly"]

SAVE_AS_DIR_PATH = Path("mail_files")

# 画像や添付ファイルがあるメールメッセージID
MESSAGE_ID = "[ここに添付ファイルや画像の埋め込みがあるhtmlメールのIDを入れる]"


def decode_base64url(data):
    """Base64URLでエンコードされたデータをデコードする"""
    if data:
        return base64.urlsafe_b64decode(data)
    return None


def download_attachment(service, userId, messageId, attachment_id, filepath):
    """
    添付ファイルをダウンロードして保存する関数
    """
    attachment = (
        service.users()
        .messages()
        .attachments()
        .get(userId=userId, messageId=messageId, id=attachment_id)
        .execute()
    )
    file_data = decode_base64url(attachment["data"])
    with open(filepath, "wb") as f:
        f.write(file_data)
    print(f"Saved attachment to {str(filepath)}")


def find_and_download_attachments(
    service, message_id: str, message_payload: dict, userId: str, directory: Path
):
    """
    メッセージから添付ファイルを探索し、ダウンロードする関数
    """
    directory.mkdir(exist_ok=True)

    for part in message_payload.get("parts", []):
        filename = part.get("filename")
        body = part.get("body", {})
        attachment_id = body.get("attachmentId")

        if filename and attachment_id:
            # 添付ファイルが見つかった場合、ダウンロード
            print(f"filename: {filename}, attachment_id: {attachment_id}")
            filepath = directory / filename
            download_attachment(service, userId, message_id, attachment_id, filepath)

        if "parts" in part:
            # 入れ子になっている場合は再帰的に探索
            find_and_download_attachments(service, message_id, part, userId, directory)


def main():
    creds = get_cledential(SCOPES)
    try:
        service = build("gmail", "v1", credentials=creds)

        # メッセージの取得
        message = service.users().messages().get(userId="me", id=MESSAGE_ID).execute()

        print(f"Message ID: {message['id']}")
        print(f"Message snippet: {message['snippet']}")

        # 添付ファイルの取得
        message_payload = message["payload"]
        find_and_download_attachments(
            service, MESSAGE_ID, message_payload, "me", SAVE_AS_DIR_PATH
        )

    # エラーハンドリング
    except HttpError as error:
        print(f"An error occurred: {error}")


if __name__ == "__main__":
    main()

# googleauth_util.py
from pathlib import Path

from google.auth.transport.requests import Request
from google.oauth2.credentials import Credentials
from google_auth_oauthlib.flow import InstalledAppFlow

# トークンとクレデンシャルの保存先
token_save_path = Path("google_api_access_token.json")
cred_json = Path("credentials.json")


# クレデンシャルの取得用の関数
def get_cledential(scopes: list[str]) -> Credentials:
    """
    Google APIの認証情報をOAuth2の認証フロー（クライアントシークレット）で取得します。
    既に認証情報があればそれを返します。
    リフレッシュトークンに対応しています。
    なければ認証情報を取得し、google_api_access_token.jsonに保存します。
    args:
        scopes: 認証情報を取得する際に必要なスコープ
    return:
        認証情報
    """
    creds = None
    if token_save_path.exists():
        creds = Credentials.from_authorized_user_file(token_save_path, scopes)
    if not creds or not creds.valid:
        if creds and creds.expired and creds.refresh_token:
            creds.refresh(Request())
        else:
            flow = InstalledAppFlow.from_client_secrets_file(cred_json, scopes)
            creds = flow.run_local_server(port=8081)
        with token_save_path.open("w") as token:
            token.write(creds.to_json())
    return creds