Каталог MCP

alilxxey/openobserve-community-mcp

MCP сервер для OpenObserve Community Edition в режиме read-only через stdio и REST API. Выполняет поиск логов, просмотр схем потоков и дашбордов. Интегрируется с Claude и Codex для анализа данных OpenObserve без права записи.

README

8 инструментов

Версии

Установить сервер

OpenObserve MCP

stdio MCP server for OpenObserve Community Edition, using only the regular REST API.

This package is designed for local MCP clients such as Claude and Codex.

What it is:

stdio only
Community Edition only
read-only only
regular OpenObserve REST API only
no native /mcp endpoint

The server can boot without an active OpenObserve configuration so hosted MCP platforms can start it, but every tool call still requires a reachable external OpenObserve instance configured via OO_BASE_URL and credentials.

Quick Start

1. Create a config file

uvx --from openobserve-community-mcp openobserve-mcp init-config

This creates a sample config at:

~/.config/openobserve-mcp/config.env

Edit it:

vim ~/.config/openobserve-mcp/config.env

Example:

OO_BASE_URL=https://openobserve.example.com
# Optional if the credentials have access to exactly one organization.
# OO_ORG_ID=default
OO_AUTH_MODE=basic
OO_USERNAME=your_username
OO_PASSWORD=your_password
OO_TIMEOUT_SECONDS=20
OO_VERIFY_SSL=true

2. Add it to Claude

claude mcp add -s user openobserve-community -- uvx --from openobserve-community-mcp openobserve-mcp

Инструменты были проиндексированы: 09.09.2026

get_dashboard

Получает определение дашборда по идентификатору.

Параметры

dashboard_idstringобязательный
include_rawboolean

get_latest_traces

Получает последние данные трассировки из потока трассировки. start_time и end_time принимают метки времени Unix в секундах, миллисекундах, микросекундах или наносекундах и нормализуются до микросекунд.

Параметры

end_timeintegerобязательный
filter_querystring | null
include_rawboolean
offsetinteger
sizeinteger
start_timeintegerобязательный
stream_namestringобязательный
timeoutinteger | null

get_stream_schema

Получает информацию о схеме для конкретного потока. Сначала использует эту информацию для подтверждения реальных имен полей перед написанием SQL; многие потоки логов выдают message, а не log. Увеличивает fields_limit для просмотра большего количества полей из больших схем.

Параметры

fields_limitinteger
include_rawboolean
stream_namestringобязательный

list_dashboards

Выводит список дашбордов в текущей организации.

Параметры

folderstring | null
include_rawboolean
page_sizeinteger | null
titlestring | null

list_streams

Перечисляет потоки, доступные в текущей организации.

Параметры

include_rawboolean
keywordstring
limitinteger
offsetinteger
sortstring
stream_typestring

search_around

Получает записи вокруг конкретной записи в журнале. Параметр key принимает временные метки Unix в секундах, миллисекундах, микросекундах или наносекундах для удобства, но лучший ввод — это точный _timestamp, возвращённый search_logs; иначе OpenObserve может не вернуть близлежащие строки. output_format может быть 'records' или 'columns' для более токен-эффективной формы таблицы. record_profile может быть 'generic' или 'kubernetes_compact'.

Параметры

include_rawboolean
keyintegerобязательный
output_formatstring
record_profilestring
regionsstring | null
sizeinteger
stream_namestringобязательный
timeoutinteger | null

search_logs

Выполняет полный SQL-поиск по логам OpenObserve. Пример построчного запроса: SELECT _timestamp, message FROM "my_stream" ORDER BY _timestamp DESC LIMIT 20. Пример агрегатного запроса: SELECT level, count(*) AS cnt FROM "my_stream" GROUP BY level ORDER BY cnt DESC LIMIT 20. В сомнительных случаях используйте двойные кавычки вокруг имён потоков в SQL, а актуальные имена полей проверяйте через get_stream_schema, не предполагая, что столбец обязательно называется log. start_time и end_time принимают метки времени Unix в секундах, миллисекундах, микросекундах или наносекундах и нормализуются до микросекунд. Параметр limit задаёт размер страницы API; если ваша конфигурация OpenObserve/DataFusion всё ещё жалуется на ORDER BY без SQL LIMIT, добавьте явный LIMIT и в SQL. output_format может быть 'records' или 'columns'; 'columns' особенно удобен для широких запросов SELECT * и позволяет сэкономить примерно 35–40% токенов. record_profile может быть 'generic' или 'kubernetes_compact'; компактный профиль Kubernetes обрезает типичные шумные поля метаданных, такие как метки подов и IP-метаданные подов.

Параметры

end_timeintegerобязательный
include_rawboolean
limitinteger
offsetinteger
output_formatstring
record_profilestring
sqlstringобязательный
start_timeintegerобязательный
timeoutinteger | null
use_cacheboolean

search_values

Получает уникальные значения полей для потока за временной интервал. stream_name: необработанный сегмент пути имени потока, например my_stream; не заключайте его в кавычки, как SQL. fields: список полей, разделенных запятыми. filter_query использует синтаксис фильтра _values из OpenObserve, например kubernetes_pod_namespace=litellm. Простые равенства в стиле SQL, например kubernetes_pod_namespace='litellm', нормализуются автоматически. start_time и end_time принимают временные метки Unix в секундах, миллисекундах, микросекундах или наносекундах и нормализуются до микросекунд. В этом инструменте total означает количество возвращенных групп полей, а не общее количество совпадающих записей журнала.

Параметры

end_timeintegerобязательный
fieldsstringобязательный
filter_querystring | null
include_rawboolean
keywordstring | null
no_countboolean
offsetinteger
regionsstring | null
sizeinteger
start_timeintegerобязательный
stream_namestringобязательный
timeoutinteger | null

Github Сайт сервера

Конфиг для установки сервера

{
  "command": "uvx",
  "args": [
    "--from",
    "openobserve-community-mcp",
    "openobserve-mcp"
  ]
}

Нужен uvx

Сервер запускается через uvx
Без него ничего работать не будет.

Как установить uvx

FAQ

Для чего этот сервер?

Этот MCP-сервер даёт AI-ассистентам вроде Claude или Codex прямой доступ к данным OpenObserve. Помогает искать логи, смотреть схемы потоков, загружать дашборды и трассы — прямо из чата. Разработчикам не нужно переключаться между инструментами, чтобы разобраться в инциденте или проанализировать события. Всё работает через обычный REST API, без лишних танцев с настройкой.

Что он умеет?

Сервер получает список потоков в организации, извлекает схему выбранного потока для подтверждения имён полей, выполняет полноценный SQL-поиск по логам, отбирает записи вокруг конкретной записи, получает уникальные значения полей за временной интервал, перечисляет доступные дашборды, получает определение дашборда по идентификатору и загружает последние данные трассировки из потока трассировок.