Home-Assistant
/
core
mirror of https://github.com/home-assistant/core.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix too verbose HTTP logging for Azure Data Explorer (#121802)

pull/121858/head
Marcel Vriend 2024-07-12 16:09:44 +02:00 committed by GitHub
parent 5f02f3caa9
commit 156e92a4cd
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
homeassistant/components/azure_data_explorer/client.py
View File

@ -65,13 +65,18 @@ class AzureDataExplorerClient:
) )
if data[CONF_USE_QUEUED_CLIENT] is True: if data[CONF_USE_QUEUED_CLIENT] is True:
# Queded is the only option supported on free tear of ADX # Queued is the only option supported on free tier of ADX
self.write_client = QueuedIngestClient(kcsb_ingest) self.write_client = QueuedIngestClient(kcsb_ingest)
else: else:
self.write_client = ManagedStreamingIngestClient.from_dm_kcsb(kcsb_ingest) self.write_client = ManagedStreamingIngestClient.from_dm_kcsb(kcsb_ingest)
self.query_client = KustoClient(kcsb_query) self.query_client = KustoClient(kcsb_query)
# Reduce the HTTP logging, the default INFO logging is too verbose.
logging.getLogger("azure.core.pipeline.policies.http_logging_policy").setLevel(
logging.WARNING
)
def test_connection(self) -> None: def test_connection(self) -> None:
"""Test connection, will throw Exception if it cannot connect.""" """Test connection, will throw Exception if it cannot connect."""
@ -80,7 +85,7 @@ class AzureDataExplorerClient:
self.query_client.execute_query(self._database, query) self.query_client.execute_query(self._database, query)
def ingest_data(self, adx_events: str) -> None: def ingest_data(self, adx_events: str) -> None:
"""Send data to Axure Data Explorer.""" """Send data to Azure Data Explorer."""
bytes_stream = io.StringIO(adx_events) bytes_stream = io.StringIO(adx_events)
stream_descriptor = StreamDescriptor(bytes_stream) stream_descriptor = StreamDescriptor(bytes_stream)