def ingest_from_blob()

in azure-kusto-ingest/azure/kusto/ingest/managed_streaming_ingest_client.py [0:0]

• 14 lines of code
• 5 McCabe index (conditional complexity)

    def ingest_from_blob(self, blob_descriptor: BlobDescriptor, ingestion_properties: IngestionProperties):
        """
        Enqueue an ingest command from azure blobs.

        For ManagedStreamingIngestClient, this method always uses Queued Ingest, since it would be easier and faster to ingest blobs.

        To learn more about ingestion methods go to:
        https://docs.microsoft.com/en-us/azure/data-explorer/ingest-data-overview#ingestion-methods
        :param azure.kusto.ingest.BlobDescriptor blob_descriptor: An object that contains a description of the blob to be ingested.
        :param azure.kusto.ingest.IngestionProperties ingestion_properties: Ingestion properties.
        """
        IngestTracingAttributes.set_ingest_descriptor_attributes(blob_descriptor, ingestion_properties)

        if self._is_closed:
            raise KustoClosedError()
        blob_descriptor.fill_size()
        try:
            res = self._stream_with_retries(blob_descriptor.size, blob_descriptor, ingestion_properties)
            if res:
                return res
        except KustoApiError as ex:
            error = ex.get_api_error()
            if error.permanent:
                raise

        return self.queued_client.ingest_from_blob(blob_descriptor, ingestion_properties)