1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79

# @title GoogleDriveゴミ箱削除
from googleapiclient.discovery import build
from google.auth.transport.requests import Request
from google.oauth2.credentials import Credentials
from google.colab import auth
from google.auth import default
from tqdm import tqdm
import time

def authenticate():
    """ユーザーを認証し、Google Drive APIのサービスを構築する"""
    auth.authenticate_user()  # Colab特有の認証プロセス
    creds, _ = default()  # デフォルトの認証情報を取得
    return build('drive', 'v3', credentials=creds)

def list_all_trashed_files(service):
    """ゴミ箱内のすべてのファイルを古い順にリスト化"""
    items = []
    page_token = None
    query = "trashed=true"
    fields = "nextPageToken, files(id, name, parents, createdTime)"
    
    # ページネーションを処理しつつ、すべての削除対象ファイルをリスト化
    while True:
        results = service.files().list(q=query, orderBy="createdTime", fields=fields, pageToken=page_token).execute()
        items.extend(results.get('files', []))
        page_token = results.get('nextPageToken', None)
        if not page_token:
            break

    return items

def get_full_file_path(service, file_id):
    """ファイルIDからファイルパスを取得する"""
    try:
        path_elements = []
        current_file = service.files().get(fileId=file_id, fields='id, name, parents').execute()

        # 親フォルダをたどりながらパスを生成
        while 'parents' in current_file:
            parent_id = current_file['parents'][0]
            current_file = service.files().get(fileId=parent_id, fields='id, name, parents').execute()
            path_elements.insert(0, current_file['name'])

        path_elements.append(current_file['name'])
        return '/' + '/'.join(path_elements)
    except Exception as e:
        return f"パス取得失敗: {str(e)}"

def delete_file(service, file):
    """単一のファイルを削除し、結果を表示"""
    try:
        file_path = get_full_file_path(service, file['id'])
        service.files().delete(fileId=file['id']).execute()
        print(f"削除: {file['name']} (ID: {file['id']}) - パス: {file_path}")
    except Exception as e:
        print(f"削除失敗: {file['name']} (ID: {file['id']}) - エラー: {str(e)}")

def empty_trash(service):
    """ゴミ箱内のファイルを削除し、進捗を表示"""
    items = list_all_trashed_files(service)

    if not items:
        print("ゴミ箱に削除対象ファイルはありません。")
        return

    total_items = len(items)
    print(f"削除対象の総ファイル数: {total_items}")

    # tqdmで進捗表示
    with tqdm(total=total_items, desc="ファイル削除中", unit="file") as pbar:
        for file in items:
            delete_file(service, file)
            pbar.update(1)

# メイン処理
if __name__ == '__main__':
    service = authenticate()
    empty_trash(service)