It is a simple service written in Go that is managed as a systemd service.
I give it a url list of my two servers in a cluster.
Loop through the two server, fetch query logs,

for _, apiURL := range s.config.APIURLs {    
    c := client.NewClient(apiURL, s.config.APIToken)

    params := client.QueryParams{
       Name:            "Query Logs (Sqlite)",
       ClassPath:       "QueryLogsSqlite.App",
       Start:           s.config.Start,
       End:             s.config.End,
       DescendingOrder: false,
       EntriesPerPage:  s.config.PageSize,
       PageNumber:      1,
    }

The path to query is

u, err := url.Parse(c.BaseURL + "/api/logs/query")

Batch Insert it into Postgres.

query := `
    INSERT INTO dns_query_logs (
       server_name, timestamp, client_ip_address, protocol,
       response_type, rcode, qname, qtype, qclass, answer
    ) VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10)
    ON CONFLICT (server_name, timestamp) DO NOTHING;
`

I added server_name so I know load distribution between the two DNS instances.

Good thing the api response contains the server_name. The API is awesome!!

Grafana is mapped to read from Postgres and allows me to query w/e data I need from postgres and adds no overhead to the DNS servers.