humio stdin testing

set_token.py

import requests
from time import sleep

while True:
    try:
        if requests.get("http://localhost:8080").status_code == 200:
            break
        else:
            sleep(5)
    except:
        sleep(5)


headers = {
    'Accept': 'application/json, multipart/mixed',
    'Accept-Language': 'en-US,en;q=0.5',
    'content-type': 'application/json',
    'Authorization': 'Bearer null',
    'Origin': 'http://localhost:8080',
    'Connection': 'keep-alive',
}

data = '{"query":"mutation {\\n enableFeature(feature: CustomIngestTokens)\\n}\\n","variables":null}'

response = requests.post('http://localhost:8080/graphql', headers=headers, data=data)

print(response.json())

data = '{"query":"mutation {\\n addIngestToken(\\n repositoryName: \\"sandbox\\",\\n name: \\"MyIngestToken\\",\\n customToken: \\"abcdabcdabcdabcd\\",\\n ) {\\n ingestToken {\\n name\\n token\\n }\\n }\\n}\\n","variables":null}'

response = requests.post('http://localhost:8080/graphql', headers=headers, data=data)

print(response.json())

quit()

start_docker.sh

mkdir -p /tmp/humio/mounts/humio /tmp/humio/mounts/kafka-data /tmp/humio/mounts/data
docker run -d -v /tmp/humio/mounts/data:/data -v /tmp/humio/mounts/kafka-data:/data/kafka-data -v /tmp/humio/mounts/humio:/etc/humio:ro --net=host -p 8080:8080 --ulimit="nofile=8192:8192" humio/humio:1.25.3

vector.toml

[sources.in]
type = "stdin"
decoding.codec="json"

[sinks.out]
type = "humio_logs"
inputs = [ "in" ]
compression = "none"
encoding.codec = "json"
token = "abcdabcdabcdabcd"
endpoint = "http://localhost:8080"