Python Requests to ship logs to Loki API

ship_logs_to_loki.py

#!/usr/bin/env python3
# docs: https://grafana.com/docs/loki/latest/api/#post-lokiapiv1push

import requests
import time

# variables
LOKI_USERNAME="x"
LOKI_PASSWORD="x"
LOKI_ENDPOINT="https://loki-api.example.com/loki/api/v1/push"

def generate_log_message(message):
    headers = {"content-type":"application/json"}
    data = {
        "streams": [{
            "stream": { "job": "python-requests", "env": "test", "level": "info" },
            "values": [ [ time.time_ns(), message ] ]
        }]
    }
    response = requests.post(LOKI_ENDPOINT, headers=headers, json=data, auth=(LOKI_USERNAME, LOKI_PASSWORD))
    return response.status_code

response = generate_log_message("this is a test")
print(response)

ze_screeshot.md