Fluentd input plugin: periodically pulls SQL diagnostics from OceanBase Cloud . Each event is one execution sample

Every record includes ob_log_type (slow_sql or top_sql). With include_metadata true (default), records also get ob_instance_id, ob_tenant_id, and the query time window.

For Grafana Loki output you additionally need fluent-plugin-grafana-loki.

gem install fluent-plugin-oceanbase-logs

1. Create an AccessKey in OceanBase Cloud — AccessKey.
2. In the console, copy Instance ID and Tenant ID

Typical pattern in Fluentd:

access_key_id     "#{ENV['OCEANBASE_ACCESS_KEY_ID']}"
access_key_secret "#{ENV['OCEANBASE_ACCESS_KEY_SECRET']}"
instance_id       "#{ENV['OCEANBASE_INSTANCE_ID']}"
tenant_id         "#{ENV['OCEANBASE_TENANT_ID']}"

Optional: OCEANBASE_ENDPOINT, OCEANBASE_FETCH_INTERVAL, OCEANBASE_LOOKBACK_SECONDS, OCEANBASE_DB_NAME, OCEANBASE_SEARCH_KEYWORD, OCEANBASE_PROJECT_ID — see .env.example and the Docker table below.

Full sample: example/fluentd.conf.

<source>
  @type oceanbase_logs
  tag  oceanbase.slow_sql
  log_type slow_sql
  access_key_id     "#{ENV['OCEANBASE_ACCESS_KEY_ID']}"
  access_key_secret "#{ENV['OCEANBASE_ACCESS_KEY_SECRET']}"
  instance_id       "#{ENV['OCEANBASE_INSTANCE_ID']}"
  tenant_id         "#{ENV['OCEANBASE_TENANT_ID']}"
  endpoint          api-cloud-cn.oceanbase.com
  fetch_interval    60
  lookback_seconds  600
  deduplicate       true
  include_metadata  true
  <storage>
    @type local
    persistent true
    path /var/log/fluentd/slow_sql_seen
  </storage>
</source>

<match oceanbase.slow_sql>
  @type file
  path /var/log/fluentd/slow_sql
  append true
  <format>
    @type json
  </format>
</match>

Ready-made stack (Loki, Fluentd, Grafana) and a slow_sql + top_sql：

cp .env.example .env   # fill in secrets
cd example/oceanbase2loki-docker && docker compose up -d

Compose-related environment (host .env or exports):

The bundled fluentd-to-loki.conf uses record.dig and avoids "; / ] patterns that break Fluentd’s config parser and record_transformer — keep that style if you edit it.