azure_monitor_logs_ingestion_with_default_credential.py

1import os
2from azure.identity import DefaultAzureCredential
3from azure.monitor.ingestion import LogsIngestionClient
4
5def main():
6    # To authenticate, your application must have a client ID, tenant ID, and client secret.
7    # See: https://learn.microsoft.com/azure/azure-monitor/logs/tutorial-logs-ingestion-portal
8    endpoint = os.environ["DATA_COLLECTION_ENDPOINT"]
9    rule_id = os.environ["DATA_COLLECTION_RULE_ID"]
10    stream_name = os.environ["STREAM_NAME"]
11
12    credential = DefaultAzureCredential()
13    client = LogsIngestionClient(endpoint=endpoint, credential=credential)
14
15    body = [
16        {
17            "Time": "2023-01-01T00:00:00.000Z",
18            "AdditionalContext": "additional context"
19        },
20        {
21            "Time": "2023-01-01T00:00:01.000Z",
22            "AdditionalContext": "more context"
23        },
24    ]
25
26    try:
27        client.upload(rule_id=rule_id, stream_name=stream_name, logs=body)
28    except Exception as e:
29        print(f"Upload failed: {e}")
30
31if __name__ == '__main__':
32    main()