Notionデータベースのレコード行を一括削除する（API, Python）

# Get DB info from query, title and id
def get_db_names_and_ids_from_query(client, query: str) -> dict:
    """
    Search for databases in Notion using a query string and return a dictionary containing database names and IDs.

    Args:
        client: The Notion client object.
        query (str): The search query string.

    Returns:
        dict: A dictionary containing 'db_title' and 'db_id' for found databases.
        If no databases are found, returns an empty dictionary.
    """
    results = client.search(query=query).get("results")

    # Dict for db_info. {db_title: db_id}
    db_names_ids = {}
    db_count = 0

    for result in results:
        # Check if the result is a database
        if result["object"] == "database":
            db_count += 1
            # db_title: db_id
            db_names_ids[result["title"][0]["plain_text"]] = result["id"]
    
    if db_count:
        print(f"Found {db_count} databases.")
        return db_names_ids
    else:
        print(f"No databases found with query: {query}")
        return {}

# データベースIDを取得
people_dbs = get_db_names_and_ids_from_query(client, query="People")

# 削除対象とするデータベース
database_id=people_dbs['People']

import time

# Get All Page info from a specific DB, even though it is more than 100 pages
def get_all_pages_info_from_db_id(self, databaseID: str) -> list:
    """Return the query of all the databases."""
    data = self.databases.query(databaseID)
    # Retrieve the object, has_more, and next_cursor
    database_object = data['object']
    has_more = data['has_more']
    next_cursor = data['next_cursor']
    while has_more == True:
        # Sleep for 2 second to avoid rate limit
        time.sleep(2)
        data_while = self.databases.query(databaseID, start_cursor=next_cursor)
        # Append the results to the data
        for row in data_while['results']:
            data['results'].append(row)
        # Update the has_more and next_cursor
        has_more = data_while['has_more']
        next_cursor = data_while['next_cursor']

    # Create a new database object with the updated data
    new_database = {
        "object": database_object,
        "results": data["results"],
        "next_cursor": next_cursor,
        "has_more": has_more
    }
    
    # Return only the results (pages)
    return new_database["results"]

# 削除対象データベースからすべてのページ情報を取得
pages_to_delete = get_all_pages_info_from_db_id(client, database_id)

# ページIDのみのリストを作成
page_ids_to_delete = [page['id'] for page in pages_to_delete]

# Delete the page
def delete_page_with_page_id(client, page_id):
    response = client.pages.update(
        **{
            "page_id": page_id,
            "in_trash": True
        }
    )
    
    return response

# Delete all the DB pages
error_cases_info = []
for page in page_ids_to_delete:
    try:
        response = delete_page_with_page_id(client, page['id'])
        print(f"Deleted page {page['id']}")
        time.sleep(3)
    except Exception as e:
        print("--------------------------------")
        print(f"Error deleting page {page['id']}: {e}")
        print("--------------------------------")
        error_cases_info.append(f"{page['id']}: {e}")
        time.sleep(3)

print("Completed!🎉")
print(f"Error cases: {error_cases_info}")