polars.Catalog.scan_table

Catalog.scan_table(
    catalog_name: str,
    namespace: str,
    table_name: str,
    *,
    delta_table_version: int | str | datetime | None = None,
    delta_table_options: dict[str,
    Any] | None = None,
    storage_options: StorageOptionsDict | None = None,
    credential_provider: CredentialProviderFunction | Literal['auto'] | None = 'auto',
    retries: int | None = None,
) → LazyFrame

Получить метаданные указанной таблицы.

Предупреждение

Эта функциональность считается нестабильной. Она может быть изменена в любой момент без того, чтобы это считалось несовместимым изменением.

Параметры:

catalog_name

Название каталога.

namespace

Название пространства имён (схема Unity).

table_name

Название таблицы.

delta_table_version

Версия таблицы для сканирования (только Deltalake).

delta_table_options

Дополнительные именованные аргументы при чтении таблицы Deltalake.

storage_options

Параметры, определяющие способ подключения к облачному провайдеру.

В настоящее время поддерживаются облачные провайдеры AWS, GCP и Azure. Список поддерживаемых ключей см. здесь:

• aws
• gcp
• azure
• Hugging Face (hf://): принимает ключ API в параметре token: {'token': '...'} или при задании переменной окружения HF_TOKEN.

Если storage_options не задан, Polars попытается определить эту информацию из переменных окружения.

credential_provider

Функция, которую можно вызвать для получения учётных данных облачного хранилища. Функция должна возвращать словарь с ключами учётных данных и необязательным временем их истечения.

Предупреждение

Эта функциональность считается нестабильной. Она может быть изменена в любой момент без того, чтобы это считалось несовместимым изменением.

retries

Количество повторных попыток при сбое доступа к облачному экземпляру.

Устарело с версии 1.37.1: Вместо этого передавайте {“max_retries”: n} через storage_options.