【Python】Cryptowatchが使えなくなったのでKrakenAPIを叩いて仮想通貨（暗号資産）のヒストリカルデータを取得

import requests

def fetch_historical_data_from_CryptoWatch():
    exchange="kraken" #取引所(kraken)
    symbol="btcusd" #通貨ペア（ビットコイン/米ドル）
    url= f"https://api.cryptowat.ch/markets/{exchange}/{symbol}/ohlc?periods=86400&after=0"

    res = requests.get(url).json()
    return res

res=fetch_historical_data_from_CryptoWatch()
print(res)

import requests
import pandas as pd
from datetime import datetime

def fetch_historical_data(symbol, start_date, end_date, interval=1440):
    """
    Kraken APIを使用して指定された通貨ペアのヒストリカルデータを取得

    Args:
    symbol (str): 取得したい通貨ペアのシンボル（例: 'XXBTZUSD'）
    start_date (datetime): データ取得の開始日時
    end_date (datetime): データ取得の終了日時
    interval (int, optional): データの間隔（分単位）。デフォルトは1440分（1日）。

    Returns:
    pandas.DataFrame: 指定された通貨ペアのヒストリカルデータを含むDataFrame。
    """
    # Unixタイムスタンプに変換
    start_timestamp = int(start_date.timestamp())
    end_timestamp = int(end_date.timestamp())

    # KrakenのOHLCエンドポイントURL
    url = 'https://api.kraken.com/0/public/OHLC'

    # データを格納するためのデータフレーム
    df = pd.DataFrame()

    while start_timestamp < end_timestamp:
        # パラメータの設定
        params = {
            'pair': symbol,
            'interval': interval,
            'since': start_timestamp
        }

        # APIリクエストを実行
        response = requests.get(url, params=params)

        # レスポンスの確認
        if response.status_code != 200:
            raise Exception(f"API request failed with status code {response.status_code}")

        # データの抽出
        data = response.json()

        # 結果を確認
        if data['error']:
            return df

        # 取得したデータを追加
        new_data = pd.DataFrame(data['result'][symbol], columns=[
            'Time', 'Open', 'High', 'Low', 'Close', 'VWAP', 'Volume', 'Count'
        ])
        new_data['Time'] = pd.to_datetime(new_data['Time'], unit='s')
        df = df.append(new_data, ignore_index=True)

        # 次のリクエストの開始タイムスタンプを更新
        start_timestamp = int(data['result']['last'])

        last = int(data['result']['last'])
        if last <= start_timestamp:
            break  # 過去のデータが更新されない場合はループを終了
        start_timestamp = last

        # 取得したデータの最新タイムスタンプがend_dateを超えた場合、ループを終了
        if df['Time'].max() > pd.Timestamp(end_date):
            break

    df=df[(df["Time"]>=start_date) & (df["Time"]<=end_date)]

    return df

#ビットコイン/USドル
symbol = 'XXBTZUSD'
start_date = datetime(2022, 11, 30)
end_date = datetime(2023, 11, 30)
historical_data = fetch_historical_data(symbol, start_date, end_date)
print(historical_data)