code: def ingest_from_blob(self, blob_descriptor, ingestion_properties):
          
          queues = self._resource_manager.get_ingestion_queues()
  
          queue_details = random.choice(queues)
          storage_client = CloudStorageAccount(queue_details.storage_account_name, sas_token=queue_details.sas)
          queue_service = storage_client.create_queue_service()
          authorization_context = self._resource_manager.get_authorization_context()
          ingestion_blob_info = _IngestionBlobInfo(
              blob_descriptor, ingestion_properties=ingestion_properties, auth_context=authorization_context
          )
          ingestion_blob_info_json = ingestion_blob_info.to_json()
          encoded = base64.b64encode(ingestion_blob_info_json.encode("utf-8")).decode("utf-8")
          queue_service.put_message(queue_name=queue_details.object_name, content=encoded)
docs: Enqueuing an ingest command from azure blobs.
          :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.