--データベースと付随情報を記載
query {
  databases {
    name
    tables {
      name
      columns {
        name
        dataType
      }
    }
  }
}

# ライブラリインポート
import requests # HTTPリクエストを送信するためのライブラリ
import json # JSON形式のデータを扱うためのライブラリ
import openpyxl # Excelファイルを扱うためのライブラリ
import pandas as pd # データ分析のためのライブラリ
import os # オペレーティングシステムの機能を扱うためのライブラリ
from datetime import datetime # 日時を扱うためのライブラリ
import csv # CSVファイルを扱うためのライブラリ

# TableauのAPI情報
TABLEAU_SERVER = 'TableauサーバーのURL'
TABLEAU_VERSION = '3.24' # 使用するAPIのバージョン
TABLEAU_TOKEN_NAME = '# Personal Access Tokenの名前'
TABLEAU_TOKEN_VALUE = 'シークレット情報の名前'

# Tableauサーバーへサインインするための情報設定
server_name = TABLEAU_SERVER
version = TABLEAU_VERSION
site_url_id = "" # Site URLのパス、空白の場合はデフォルトサイトを使用

# Personal Access Tokenを指定する
personal_access_token_name = TABLEAU_TOKEN_NAME 
personal_access_token_secret = TABLEAU_TOKEN_VALUE 

# サインインURLの設定
signin_url = "https://prod-apnortheast-a.online.tableau.com/api/{version}/auth/signin".format(version=version)

# サインインのためのペイロードを作成
payload = {
"credentials": {
"personalAccessTokenName": personal_access_token_name,
"personalAccessTokenSecret": personal_access_token_secret,
"site": {"contentUrl": site_url_id}
}
}

# リクエストヘッダーを設定
headers = {
'accept': 'application/json',
'content-type': 'application/json'
}

# サーバーにリクエストを送信してサインインする
req = requests.post(signin_url, json=payload, headers=headers, verify=False)
req.raise_for_status() # ステータスコードが200でない場合は例外を発生させる

# HTTPレスポンスを取得し、JSON形式に変換
response = json.loads(req.content)

# アクセストークンを取得
token = response["credentials"]["token"]
# Site IDを取得
site_id = response["credentials"]["site"]["id"]

# Metadata APIのエンドポイントを設定 
metadata_url = f"{TABLEAU_SERVER}/relationship-service-war/graphql"

# リクエストヘッダーを設定 
headers = { 'X-Tableau-Auth': token, # 認証トークンをヘッダーに追加 'Content-Type': 'application/json' } 

# GraphQLクエリを定義（データソース「×××」とそのフィールド情報を取得）
graphql_query = """
{
publishedDatasources(filter: { name: "×××" }) {
　name
　hasExtracts
　upstreamTables {
 　　name
 　　id
　　}
　fields {
name
id
　　}
　}
}
"""

# APIリクエストを送信
response = requests.post(metadata_url, headers=headers, json={'query': graphql_query})

# レスポンスを処理
if response.status_code == 200:
　　data = response.json() # JSON形式に変換

　　# レスポンスの確認
　　print("APIレスポンス:", data) # レスポンスを出力して確認
　　if "data" in data and data["data"] is not None:
　　published_datasources = data["data"].get("publishedDatasources", [])

　　# CSVファイルに出力
　　with open("tableau_metadata_filtered.csv", mode="w", newline="", encoding="utf-8") as file:
 　　　writer = csv.writer(file)
　　　　writer.writerow(["Type", "Name", "Has Extracts", "Upstream Tables", "Field Name", "Field ID"]) # ヘッダー行

　　　　　# 各データソースの情報をCSVに書き込む
　　　　　for datasource in published_datasources:
　　　　　　　upstream_tables = ', '.join([f"{table['name']} (ID: {table['id']})" for table in datasource["upstreamTables"]])
　　　　　　　for field in datasource.get("fields", []):
　　　　　　　　writer.writerow([
　　　　　　　　"Datasource",
　　　　　　　　datasource["name"],
　　　　　　　　datasource["hasExtracts"],
 　　　　　　　　upstream_tables,
　　　　　　　　field["name"],
　　　　　　　　field["id"],
　　　　　　　])

　　　print("CSVファイル 'tableau_metadata_filtered.csv' に出力しました。")
　　else:
 　　　print("エラー: レスポンスにデータが見つかりませんでした。")
else:
　　print(f"データの取得に失敗しました。HTTP ステータスコード: {response.status_code}")
　　print("レスポンス:", response.text)

# サインアウト
signout_url = f"{TABLEAU_SERVER}/api/{TABLEAU_VERSION}/auth/signout"
requests.post(signout_url, headers={'X-Tableau-Auth': token}) # サインアウトリクエストを送信
print("正常にサインアウトしました。")