Код: Выделить всё
storage_account_url = f"{self.datalake_settings.STORAGE_ENDPOINT}/{parquet_folder_path}/{file_name}.parquet"
storage_options = {
"account_name": self.datalake_settings.STORAGE_ACCOUNT,
"client_id": self.datalake_settings.RUNACCOUNT_ID,
"client_secret": self.datalake_settings.RUNACCOUNT_KEY.get_secret_value(),
"tenant_id": self.settings.TENANT_ID
}
df.to_parquet( storage_account_url, engine='pyarrow', compression='snappy', storage_options=storage_options )
Код: Выделить всё
azure-functions
azure-identity
azure-storage-blob
azure-monitor-opentelemetry
opentelemetry-api
opentelemetry-sdk
opentelemetry-semantic-conventions
pydantic
adlfs
azure-storage-blob
azure-storage-file-datalake

Когда я запускаю этот код, я получаю следующую ошибку:
System.Private.CoreLib: Исключение при выполнении функция:
Functions.get_exchangerates_trigger. System.Private.CoreLib: Результат:
Исключение сбоя: ImportError: Установите adlfs для доступа к Azure Datalake
Gen2 и хранилищу BLOB-объектов Azure
Есть идеи, как это исправить? Судя по всему, пакеты adlfs и blobstorage установлены.
Подробнее здесь: https://stackoverflow.com/questions/793 ... ob-storage