in azure-kusto-ingest/azure/kusto/ingest/ingest_client.py [0:0]
def __init__(self, kcsb: Union[str, KustoConnectionStringBuilder], auto_correct_endpoint: bool = True):
"""Kusto Ingest Client constructor.
:param kcsb: The connection string to initialize KustoClient.
"""
super().__init__()
if not isinstance(kcsb, KustoConnectionStringBuilder):
kcsb = KustoConnectionStringBuilder(kcsb)
if auto_correct_endpoint:
kcsb["Data Source"] = BaseIngestClient.get_ingestion_endpoint(kcsb.data_source)
self._proxy_dict: Optional[Dict[str, str]] = None
self._connection_datasource = kcsb.data_source
self._resource_manager = _ResourceManager(KustoClient(kcsb))
self._endpoint_service_type = None
self._suggested_endpoint_uri = None
self.application_for_tracing = kcsb.client_details.application_for_tracing
self.client_version_for_tracing = kcsb.client_details.version_for_tracing