nginx-clickhouse

Simple NGINX access log parser and transporter to ClickHouse database. Uses the native TCP protocol for fast, compressed batch inserts.

Features

Tails NGINX access logs in real-time
Configurable log format parsing via gonx
JSON access log support (log_format escape=json) alongside traditional text format
Log enrichment: auto-hostname, environment, service tags, status class derivation
Batch inserts into ClickHouse using the official Go client (native TCP, LZ4 compression)
Retry with exponential backoff and full jitter on ClickHouse failures
Automatic connection recovery — reconnects transparently after outages
Optional disk buffer with segment files for crash recovery (at-least-once delivery)
Server-side batching via ClickHouse async inserts (async_insert=1, wait_for_async_insert=1)
Circuit breaker to fast-fail when ClickHouse is persistently down
Bulk loading (-once) — read an entire log file and exit
Stdin support (-stdin) — pipe or stream logs from other tools
Graceful shutdown — flushes buffer on SIGTERM/SIGINT or EOF
/healthz endpoint for Kubernetes liveness/readiness probes
Prometheus metrics: buffer size, flush latency, parse errors, circuit breaker state
Expression-based filtering and sampling — drop health checks, keep only 5xx, sample 10% of 2xx, etc. via expr-lang
Structured JSON logging
Configuration via YAML file or environment variables
Minimal Docker image (scratch-based)

Quick Start

Using Docker

docker pull mintance/nginx-clickhouse

docker run --rm --net=host --name nginx-clickhouse \
  -v /var/log/nginx:/logs \
  -v /path/to/config:/config \
  -v /var/lib/nginx-clickhouse:/data \
  -d mintance/nginx-clickhouse

Build from Source

Requires Go 1.25+.

go build -o nginx-clickhouse .
./nginx-clickhouse -config_path=config/config.yml

Build Docker Image

No local Go toolchain required -- builds inside Docker using multi-stage build.

make docker

How It Works

On startup, replays any unprocessed disk buffer segments from a previous crash (if disk buffer enabled)
Tails the NGINX access log file specified in configuration
Buffers incoming log lines in memory or on disk (up to max_buffer_size)
On a configurable interval (or when the buffer is full), parses the buffered lines using the NGINX log format
Batch-inserts parsed entries into ClickHouse via the native TCP protocol, with automatic retry on failure
On shutdown (SIGTERM/SIGINT), flushes remaining buffer before exiting

Input Modes

By default, nginx-clickhouse tails a log file continuously. Two additional modes are available:

Bulk Loading (`-once`)

Read an entire log file from start to end, flush all entries, and exit. Useful for importing historical data.

./nginx-clickhouse -once -config_path=config/config.yml

The file is processed through the normal buffer/flush pipeline, so large files are handled in chunks without loading everything into memory.

Stdin (`-stdin`)

Read log lines from standard input instead of a file. Supports both piped input and continuous streaming.

# Pipe a compressed log file
zcat /var/log/nginx/access.log.1.gz | ./nginx-clickhouse -stdin -config_path=config/config.yml

# Stream from journald
journalctl -f -u nginx --output cat | ./nginx-clickhouse -stdin

When stdin reaches EOF (pipe closed), the remaining buffer is flushed and the process exits. SIGTERM/SIGINT still work for early termination.

Note: -stdin only replaces the log file source. All other configuration (ClickHouse connection, column mapping, log format) is still loaded from the config file.

If both -stdin and -once are set, -stdin takes priority.

Configuration

Configuration is loaded from a YAML file (default: config/config.yml). All values can be overridden with environment variables.

Environment Variables

Variable	Description
`LOG_PATH`	Path to NGINX access log file
`FLUSH_INTERVAL`	Batch flush interval in seconds
`MAX_BUFFER_SIZE`	Max log lines to buffer before forcing a flush (default: `10000`)
`RETRY_MAX`	Max retry attempts on ClickHouse failure (default: `3`)
`RETRY_BACKOFF_INITIAL`	Initial retry backoff in seconds (default: `1`)
`RETRY_BACKOFF_MAX`	Maximum retry backoff in seconds (default: `30`)
`BUFFER_TYPE`	Buffer type: `memory` (default) or `disk`
`BUFFER_DISK_PATH`	Directory for disk buffer segments
`BUFFER_MAX_DISK_BYTES`	Max disk usage for buffer in bytes
`CIRCUIT_BREAKER_ENABLED`	Enable circuit breaker (`true`/`false`)
`CIRCUIT_BREAKER_THRESHOLD`	Consecutive failures before opening (default: `5`)
`CIRCUIT_BREAKER_COOLDOWN`	Seconds before half-open probe (default: `60`)
`CLICKHOUSE_HOST`	ClickHouse server hostname
`CLICKHOUSE_PORT`	ClickHouse native TCP port (default: `9000`)
`CLICKHOUSE_DB`	ClickHouse database name
`CLICKHOUSE_TABLE`	ClickHouse table name
`CLICKHOUSE_USER`	ClickHouse username
`CLICKHOUSE_PASSWORD`	ClickHouse password
`CLICKHOUSE_TLS`	Enable TLS (`true`/`false`)
`CLICKHOUSE_TLS_SKIP_VERIFY`	Skip TLS certificate verification (`true`/`false`)
`CLICKHOUSE_CA_CERT`	Path to CA certificate file
`CLICKHOUSE_TLS_CERT_PATH`	Path to client TLS certificate (for mTLS)
`CLICKHOUSE_TLS_KEY_PATH`	Path to client TLS private key (for mTLS)
`CLICKHOUSE_USE_SERVER_SIDE_BATCHING`	Delegate batching to ClickHouse async inserts (`true`/`false`)
`NGINX_LOG_TYPE`	NGINX log format name
`NGINX_LOG_FORMAT`	NGINX log format string
`NGINX_LOG_FORMAT_TYPE`	Log format type: `text` (default) or `json`
`ENRICHMENT_HOSTNAME`	Hostname to add to logs (`auto` for os.Hostname)
`ENRICHMENT_ENVIRONMENT`	Environment tag (e.g., `production`)
`ENRICHMENT_SERVICE`	Service name tag
`FILTER_RULES`	Filter rules in compact format: `expr:action[:sample_rate]` separated by `;` (see Filtering & Sampling)
`ENRICHMENT_<key>`	Any other `ENRICHMENT_` var is added to the extra map (suffix lowercased, e.g. `ENRICHMENT_POD_NAMESPACE=default` sets `extra["pod_namespace"]`)

Full Config Example

See config-sample.yml for a ready-to-use template.

settings:
  interval: 5                    # flush interval in seconds
  log_path: /var/log/nginx/access.log
  seek_from_end: false           # start reading from end of file
  max_buffer_size: 10000         # flush when buffer exceeds this (prevents memory issues)
  retry:
    max_retries: 3
    backoff_initial_secs: 1
    backoff_max_secs: 30
  buffer:
    type: memory                 # "memory" (default) or "disk"
    # disk_path: /var/lib/nginx-clickhouse/buffer
    # max_disk_bytes: 1073741824 # 1GB
  circuit_breaker:
    enabled: false
    threshold: 5
    cooldown_secs: 60

clickhouse:
  db: metrics
  table: nginx
  host: localhost
  port: 9000                     # native TCP port (9440 for TLS)
  # tls: true                    # enable TLS
  # tls_insecure_skip_verify: false
  # ca_cert: /etc/ssl/clickhouse-ca.pem
  # tls_cert_path: /etc/ssl/client.crt  # client cert for mTLS
  # tls_key_path: /etc/ssl/client.key
  # use_server_side_batching: false     # delegate batching to ClickHouse async inserts
  credentials:
    user: default
    password:
  columns:                       # ClickHouse column -> NGINX variable mapping
    RemoteAddr: remote_addr
    RemoteUser: remote_user
    TimeLocal: time_local
    Request: request
    Status: status
    BytesSent: bytes_sent
    HttpReferer: http_referer
    HttpUserAgent: http_user_agent

nginx:
  log_type: main
  log_format_type: text        # "text" (default) or "json"
  log_format: '$remote_addr - $remote_user [$time_local] "$request" $status $bytes_sent "$http_referer" "$http_user_agent"'

NGINX Setup

1. Define a Log Format

In /etc/nginx/nginx.conf:

http {
    log_format main '$remote_addr - $remote_user [$time_local] "$request" $status $bytes_sent "$http_referer" "$http_user_agent"';
}

2. Enable Access Log

In your site config (/etc/nginx/sites-enabled/my-site.conf):

server {
    access_log /var/log/nginx/my-site-access.log main;
}

JSON Access Logs

nginx-clickhouse supports NGINX's native JSON log format (escape=json) as an alternative to the traditional text format. JSON logs are more robust — no custom regex parsing, no escaping edge cases.

1. Configure NGINX JSON Log Format

In /etc/nginx/nginx.conf:

log_format json_combined escape=json
'{'
  '"remote_addr":"$remote_addr",'
  '"request_method":"$request_method",'
  '"request_uri":"$request_uri",'
  '"status":$status,'
  '"body_bytes_sent":$body_bytes_sent,'
  '"request_time":$request_time,'
  '"http_referer":"$http_referer",'
  '"http_user_agent":"$http_user_agent",'
  '"time_local":"$time_local"'
'}';

2. Set Log Format Type in Config

nginx:
  log_format_type: json

With JSON format, the log_type and log_format fields are not needed. The JSON keys in the log are mapped directly via the columns config.

ClickHouse Setup

Create a table matching your column mapping. This schema uses compression codecs, monthly partitioning, and a 180-day TTL retention policy.

CREATE TABLE metrics.nginx (
    TimeLocal     DateTime    CODEC(Delta(4), ZSTD(1)),  -- delta on sequential timestamps
    Date          Date        DEFAULT toDate(TimeLocal),
    RemoteAddr    IPv4,                                   -- 4 bytes; use IPv6 for mixed traffic
    RemoteUser    String      CODEC(ZSTD(1)),
    Request       String      CODEC(ZSTD(1)),
    Status        UInt16,
    BytesSent     UInt64      CODEC(Delta(4), ZSTD(1)),
    HttpReferer   String      CODEC(ZSTD(1)),
    HttpUserAgent String      CODEC(ZSTD(1)),
    Hostname      LowCardinality(String),                 -- few distinct values
    Environment   LowCardinality(String),
    Service       LowCardinality(String),
    StatusClass   LowCardinality(String)
) ENGINE = MergeTree()
PARTITION BY toYYYYMM(Date)
ORDER BY (Status, TimeLocal)
TTL TimeLocal + INTERVAL 180 DAY                          -- adjust retention as needed
SETTINGS ttl_only_drop_parts = 1;                         -- drop whole parts, not row-by-row

Prometheus Metrics

Available at http://localhost:2112/metrics:

Metric	Description
`nginx_clickhouse_lines_processed_total`	Total log lines successfully saved
`nginx_clickhouse_lines_not_processed_total`	Total log lines that failed to save
`nginx_clickhouse_lines_read_total`	Total lines read from the log file
`nginx_clickhouse_parse_errors_total`	Total lines that failed to parse
`nginx_clickhouse_lines_filtered_total`	Total entries dropped by filter rules
`nginx_clickhouse_buffer_size`	Current number of lines in the buffer
`nginx_clickhouse_clickhouse_up`	Whether ClickHouse is reachable (1/0)
`nginx_clickhouse_flush_duration_seconds`	Time spent per flush (histogram)
`nginx_clickhouse_batch_size`	Number of entries per flush (histogram)
`nginx_clickhouse_circuit_breaker_state`	Circuit breaker state (0=closed, 1=open, 2=half-open)
`nginx_clickhouse_circuit_breaker_rejections_total`	Flushes rejected by circuit breaker

Reliability

Retry with Backoff

When a ClickHouse write fails, the client retries with exponential backoff and full jitter. Configure via:

max_retries — number of retry attempts (default: 3, set to 0 to disable)
backoff_initial_secs — initial delay between retries (default: 1s)
backoff_max_secs — maximum delay cap (default: 30s)

The backoff doubles each attempt with random jitter to avoid thundering herd.

TLS / Secure Connections

For ClickHouse Cloud or any TLS-secured cluster:

clickhouse:
  host: your-cluster.clickhouse.cloud
  port: 9440
  tls: true
  # tls_insecure_skip_verify: true    # only for self-signed certs
  # ca_cert: /etc/ssl/custom-ca.pem   # custom CA certificate
  # tls_cert_path: /etc/ssl/client.crt  # client certificate (mTLS)
  # tls_key_path: /etc/ssl/client.key   # client private key (mTLS)

The default ClickHouse secure native port is 9440. Set tls: true to enable encrypted connections. For mutual TLS (mTLS), provide both tls_cert_path and tls_key_path.

Connection Recovery

If the ClickHouse connection drops, it is automatically reset and re-established on the next retry attempt. No manual intervention needed.

Graceful Shutdown

On SIGTERM or SIGINT, the service:

Flushes any remaining buffered log lines to ClickHouse
Closes the ClickHouse connection
Exits cleanly

This ensures no data loss during deployments or container restarts.

Buffer Limits

The in-memory buffer is capped at max_buffer_size (default: 10,000 lines). When the buffer is full, it flushes immediately rather than waiting for the next interval.

Disk Buffer

For crash recovery, enable disk-backed buffering:

settings:
  buffer:
    type: disk
    disk_path: /var/lib/nginx-clickhouse/buffer
    max_disk_bytes: 1073741824  # 1GB

When enabled, log lines are written to append-only segment files on disk. If the process crashes, unprocessed segments are automatically replayed on restart. This provides at-least-once delivery.

Segment files are rotated at 10MB and deleted after successful flush.

Circuit Breaker

When ClickHouse is down for extended periods, the circuit breaker prevents wasting resources on retries:

settings:
  circuit_breaker:
    enabled: true
    threshold: 5        # open after 5 consecutive failures
    cooldown_secs: 60   # wait 60s before probing

States:

Closed (normal): all flushes proceed
Open: flushes are skipped, lines counted as not processed
Half-open: after cooldown, one probe flush is attempted. Success closes the circuit; failure re-opens it.

Monitor via nginx_clickhouse_circuit_breaker_state (0=closed, 1=open, 2=half-open) and nginx_clickhouse_circuit_breaker_rejections_total.

Server-Side Batching

By default, nginx-clickhouse batches log lines client-side using its internal buffer. You can optionally delegate batching to ClickHouse's async inserts:

clickhouse:
  use_server_side_batching: true

When enabled, each batch insert is sent with async_insert=1 and wait_for_async_insert=1. ClickHouse buffers the data server-side and flushes based on its own thresholds (async_insert_max_data_size, async_insert_busy_timeout_ms). The wait_for_async_insert=1 setting ensures the insert only returns after the server flush completes, preserving at-least-once delivery guarantees.

Client-side buffering (interval-based flush, max_buffer_size) still applies — ClickHouse recommends batching even with async inserts for best throughput. The disk buffer is redundant when server-side batching is enabled (a warning is logged if both are active).

Enrichments

Enrichments let you automatically inject additional fields into every log entry — hostname, environment, service name, and derived status class — without any changes to the NGINX log format.

Configure enrichments in the settings block:

settings:
  enrichments:
    hostname: auto
    environment: production
    service: my-api

clickhouse:
  columns:
    Hostname: _hostname
    Environment: _environment
    Service: _service
    StatusClass: _status_class

Map enrichment fields to ClickHouse columns using the _ prefix in the column mapping. Available enrichment fields:

Field	Description
`_hostname`	Hostname of the machine running nginx-clickhouse (`auto` resolves via `os.Hostname()`, or set a literal value)
`_environment`	Environment tag (e.g., `production`, `staging`)
`_service`	Service name tag
`_status_class`	HTTP status class derived from the `status` field (e.g., `2xx`, `4xx`, `5xx`)
`_extra.<key>`	Arbitrary key-value pairs from the `enrichments.extra` map

Filtering & Sampling

Filter and sample parsed log entries before they are saved to ClickHouse. Rules use the expr expression language and are evaluated post-parse against structured log fields.

Configuration

settings:
  filters:
    - expr: 'request contains "/health"'
      action: drop                         # drop health check noise
    - expr: 'status >= 200 && status < 300'
      action: drop
      sample_rate: 0.9                     # drop 90% of 2xx (keep 10%)
    - expr: 'request_time == 0'
      action: drop                         # drop cached responses
    - expr: 'status >= 500'
      action: keep                         # keep only 5xx

Each rule has:

expr — boolean expression evaluated against log fields
action — drop (remove matching entries) or keep (retain only matching entries)
sample_rate (optional, 0-1) — fraction of matches affected by the action. On a drop rule, 0.9 means drop 90% of matches (keep 10%). On a keep rule, 0.1 means retain 10% of matches (drop the rest along with non-matching entries).

Rules are applied sequentially: drop rules remove entries first, then keep rules narrow the remainder.

Available Fields

Expressions can reference any NGINX log field from your column mapping. Numeric fields are automatically converted for comparisons:

Type	Fields
Integer	`status`, `bytes_sent`, `body_bytes_sent`, `request_length`, `connection`, `connections_active`, `connections_waiting`
Float	`request_time`, `upstream_response_time`, `upstream_connect_time`, `upstream_header_time`, `msec`
String	`remote_addr`, `remote_user`, `request`, `http_referer`, `http_user_agent`, and any other field

Expression Examples

# Numeric comparisons (no type casting needed)
- expr: 'status >= 500'
- expr: 'request_time > 1.0'
- expr: 'bytes_sent == 0'

# String operations
- expr: 'request contains "/api/v2"'
- expr: 'http_user_agent contains "bot"'
- expr: 'request matches "^GET /health"'      # regex

# Combined conditions
- expr: 'status == 200 && request contains "/health"'
- expr: 'status >= 400 || request_time > 5'

Environment Variable

For simple rules, use the FILTER_RULES env var with compact expr:action[:sample_rate] format, separated by ;:

FILTER_RULES="status >= 500:keep;request_time == 0:drop"

Note: FILTER_RULES uses : as a delimiter. Expressions containing : (e.g., URLs) should use YAML config instead.

Validation

Filter expressions are compiled and validated at startup. Invalid expressions cause the service to exit with an error. Use -check to validate filters without starting:

✓ Filters: 3 rules compiled

Monitor nginx_clickhouse_lines_filtered_total to track how many entries are being dropped.

Health Check

GET /healthz on port 2112 returns:

200 OK — ClickHouse connection is alive
503 Service Unavailable — ClickHouse is unreachable

Use for Kubernetes liveness/readiness probes:

livenessProbe:
  httpGet:
    path: /healthz
    port: 2112
  initialDelaySeconds: 10
  periodSeconds: 30
readinessProbe:
  httpGet:
    path: /healthz
    port: 2112
  initialDelaySeconds: 5
  periodSeconds: 10

Kubernetes Deployment

Example manifests are provided in examples/kubernetes/ for two deployment modes:

Sidecar: runs alongside NGINX in the same pod, reads logs from a shared emptyDir volume
DaemonSet: one instance per node, reads from a hostPath log directory

The manifests include Downward API integration for automatic pod metadata enrichment (pod name, namespace, node name, pod IP) via ENRICHMENT_* env vars.

See the Kubernetes examples README for full setup instructions.

Logging

All logs are emitted as structured JSON (via logrus), making them easy to parse, ship, and alert on:

{"entries":150,"level":"info","msg":"saved log entries","time":"2026-03-22T12:00:00Z"}
{"error":"connection refused","level":"error","msg":"can't save logs","time":"2026-03-22T12:00:05Z"}

Grafana Dashboard

A pre-built Grafana dashboard is included in grafana/dashboard.json.

Requirements: Official Grafana ClickHouse plugin (v4.0+), Grafana 10+.

Import: Grafana > Dashboards > Import > Upload JSON file. Set the Database and Table template variables to match your config.

Panels (16):

Row	Panels
Overview	Total Requests, RPS, Error Rate %, Avg Response Time, P95, P99
Traffic	Requests by Status Class (stacked bar), Requests by Method (donut)
Performance	Response Time (avg/p95/p99), Error Rate Over Time, Bandwidth, RPS Over Time
Top N	Top 10 URLs, Top 10 Client IPs, Top 10 User Agents
Logs	Slow & Error Requests table (status >= 400 or response time > 1s)

Template variables: database (default: metrics), table (default: nginx).

Config Validation

Run -check to validate your configuration without starting the service:

./nginx-clickhouse -config_path=config/config.yml -check

Output:

✓ Config loaded
✓ Log format: JSON
✓ Filters: 3 rules compiled
✓ Log file: /var/log/nginx/access.log
✓ ClickHouse connection: OK (localhost:9000)
✓ Database: OK ("metrics" exists)
✓ Table: OK ("metrics.nginx" exists)
✓ Columns: OK (8/8 columns match)

All checks passed.

Validates: config syntax, log file existence, ClickHouse connectivity, database/table existence, and column mapping against the actual table schema. Exits with code 1 if any check fails.

Contributing

See CONTRIBUTING.md for development setup, code style, and pull request guidelines.

License

Apache License 2.0

Name		Name	Last commit message	Last commit date
Latest commit History 58 Commits
.github/workflows		.github/workflows
buffer		buffer
circuitbreaker		circuitbreaker
clickhouse		clickhouse
config		config
examples/kubernetes		examples/kubernetes
filter		filter
grafana		grafana
nginx		nginx
retry		retry
.gitignore		.gitignore
CLAUDE.md		CLAUDE.md
CONTRIBUTING.md		CONTRIBUTING.md
Dockerfile		Dockerfile
LICENSE		LICENSE
Makefile		Makefile
README.md		README.md
SECURITY.md		SECURITY.md
config-sample.yml		config-sample.yml
e2e_test.go		e2e_test.go
go.mod		go.mod
go.sum		go.sum
main.go		main.go
main_test.go		main_test.go

Folders and files

Latest commit

History

Repository files navigation

nginx-clickhouse

Features

Quick Start

Using Docker

Build from Source

Build Docker Image

How It Works

Input Modes

Bulk Loading (-once)

Stdin (-stdin)

Configuration

Environment Variables

Full Config Example

NGINX Setup

1. Define a Log Format

2. Enable Access Log

JSON Access Logs

1. Configure NGINX JSON Log Format

2. Set Log Format Type in Config

ClickHouse Setup

Prometheus Metrics

Reliability

Retry with Backoff

TLS / Secure Connections

Connection Recovery

Graceful Shutdown

Buffer Limits

Disk Buffer

Circuit Breaker

Server-Side Batching

Enrichments

Filtering & Sampling

Configuration

Available Fields

Expression Examples

Environment Variable

Validation

Health Check

Kubernetes Deployment

Logging

Grafana Dashboard

Config Validation

Contributing

License

About

Topics

Resources

License

Contributing

Security policy

Uh oh!

Stars

Watchers

Forks

Releases 13

Packages 0

Uh oh!

Uh oh!

Contributors

Uh oh!

Languages

Bulk Loading (`-once`)

Stdin (`-stdin`)

Packages