in azure-kusto-ingest/azure/kusto/ingest/ingest_client.py [0:0]
def ingest_from_file(self, file_descriptor: Union[FileDescriptor, str], ingestion_properties: IngestionProperties) -> IngestionResult:
"""Enqueue an ingest command from local files.
To learn more about ingestion methods go to:
https://docs.microsoft.com/en-us/azure/data-explorer/ingest-data-overview#ingestion-methods
:param file_descriptor: a FileDescriptor to be ingested.
:param azure.kusto.ingest.IngestionProperties ingestion_properties: Ingestion properties.
"""
file_descriptor = FileDescriptor.get_instance(file_descriptor)
IngestTracingAttributes.set_ingest_descriptor_attributes(file_descriptor, ingestion_properties)
super().ingest_from_file(file_descriptor, ingestion_properties)
containers = self._get_containers()
file_descriptor, should_compress = BaseIngestClient._prepare_file(file_descriptor, ingestion_properties)
with file_descriptor.open(should_compress) as stream:
blob_descriptor = self.upload_blob(
containers,
file_descriptor,
ingestion_properties.database,
ingestion_properties.table,
stream,
self._proxy_dict,
self._SERVICE_CLIENT_TIMEOUT_SECONDS,
self._MAX_RETRIES,
)
return self.ingest_from_blob(blob_descriptor, ingestion_properties=ingestion_properties)