ParallelDataCollection.export_to_csv_files

coinmetrics._data_collection.ParallelDataCollection.export_to_csv_files(
    data_directory=None,
    columns_to_store=None,
    compress=False,
)

Export the parallelized request to a directory of CSV files, one file per combination of the parallelize_on attribute of the parent ParallelDataCollection.

Examples:

client.get_market_trades(
    "coinbase-eth-btc-spot,coinbase-eth-usdc-spot",
).parallel(["markets"]).export_to_csv_files()

produces:

./market-trades/coinbase-eth-btc-spot.csv
./market-trades/coinbase-eth-usdc-spot.csv

Layering a time_increment on top:

client.get_asset_metrics(
    "btc,eth", "ReferenceRateUSD",
    start_time="2024-01-01", limit_per_asset=1,
).parallel(
    "assets,metrics",
    time_increment=timedelta(days=1),
).export_to_csv_files()

produces:

./asset-metrics/btc/ReferenceRateUSD/start_time=2024-01-01T00-00-00Z.csv
./asset-metrics/eth/ReferenceRateUSD/start_time=2024-01-01T00-00-00Z.csv

• Parameters:

  • data_directory (Optional [str ]) -- Path to the directory where files should be written. Defaults to the current working directory.

  • columns_to_store (Optional *[*List [str ] ]) -- Columns to include in each CSV. Defaults to every column returned by the endpoint.

  • compress (bool) -- Whether to gzip the resulting files.

Returns:

• None