aligned.AzureBlobConfig

class documentation

class AzureBlobConfig(Directory): (source)

Constructors: AzureBlobConfig.from_account_id(account_id, account_name), AzureBlobConfig.from_tenant(tenant_id, account_name, client_id, client_secret)

View In Hierarchy

Undocumented

Static Method	`from_account_id`	Undocumented
Static Method	`from_tenant`	Undocumented
Method	`client`	Undocumented
Method	`csv_at`	Undocumented
Method	`delta_at`	Undocumented
Method	`directory`	Undocumented
Method	`json_at`	Undocumented
Method	`needed_configs`	Undocumented
Method	`parquet_at`	Undocumented
Method	`partitioned_parquet_at`	Undocumented
Method	`read_creds`	Undocumented
Method	`sub_directory`	Undocumented
Method	`with_schema_version`	Undocumented
Class Variable	`account_id`	Undocumented
Class Variable	`account_name`	Undocumented
Class Variable	`client_id`	Undocumented
Class Variable	`client_secret`	Undocumented
Class Variable	`tenant_id`	Undocumented
Property	`as_markdown`	Undocumented
Property	`storage`	Undocumented

@staticmethod
def from_account_id(account_id: str | ConfigValue, account_name: str | ConfigValue) -> AzureBlobConfig: (source) ¶

Undocumented

@staticmethod
def from_tenant(tenant_id: str | ConfigValue, account_name: str | ConfigValue, client_id: str | ConfigValue, client_secret: str | ConfigValue) -> AzureBlobConfig: (source) ¶

Undocumented

def client(self) -> BlobServiceClient: (source) ¶

Undocumented

def csv_at(self, path: str, mapping_keys: dict[str, str] | None = None, csv_config: CsvConfig | None = None, date_formatter: DateFormatter | None = None) -> AzureBlobCsvDataSource: (source) ¶

overrides aligned.Directory.csv_at

Undocumented

def delta_at(self, path: str, mapping_keys: dict[str, str] | None = None, config: DeltaFileConfig | None = None, date_formatter: DateFormatter | None = None) -> AzureBlobDeltaDataSource: (source) ¶

overrides aligned.Directory.delta_at

Undocumented

def directory(self, path: str | ConfigValue) -> AzureBlobDirectory: (source) ¶

Undocumented

def json_at(self, path: str) -> StorageFileReference: (source) ¶

overrides aligned.Directory.json_at

Undocumented

def needed_configs(self) -> list[ConfigValue]: (source) ¶

Undocumented

def parquet_at(self, path: str, mapping_keys: dict[str, str] | None = None, config: ParquetConfig | None = None, date_formatter: DateFormatter | None = None) -> AzureBlobParquetDataSource: (source) ¶

overrides aligned.Directory.parquet_at

Undocumented

def partitioned_parquet_at(self, directory: str, partition_keys: list[str], mapping_keys: dict[str, str] | None = None, config: ParquetConfig | None = None, date_formatter: DateFormatter | None = None) -> AzureBlobPartitionedParquetDataSource: (source) ¶

overrides aligned.Directory.partitioned_parquet_at

Undocumented