Function getClickhouseLogs

App/API/AdminHealth.ts:2252–2389

()

 * failed queries (it can embed row predicates) and keep only the exception.
 */
async function getClickhouseLogs(): Promise<JSONObject> {
  const result: JSONObject = {
    connected: false,
    note: "Recent ClickHouse errors and (when enabled) server log lines. For the full container log use `kubectl logs` / `docker logs` on the ClickHouse pod.",
    errors: [],
    recentLogEntries: [],
    failedQueries: [],
    crashes: [],
  };

  try {
    const client: ReturnType<typeof ClickhouseAppInstance.getDataSource> =
      ClickhouseAppInstance.getDataSource();

    if (!client) {
      return result;
    }

    result["connected"] = true;

    // system.errors — always available; aggregated error counters.
    try {
      const errorsResult: ClickhouseJsonResult = (await (
        await client.query({
          query:
            "SELECT name, code, value AS count, toString(last_error_time) AS last_error_time, substring(last_error_message, 1, 1000) AS last_error_message FROM system.errors WHERE value > 0 ORDER BY last_error_time DESC LIMIT 100" +
            CH_DIAG_QUERY_SETTINGS,
          format: "JSON",
        })
      ).json()) as ClickhouseJsonResult;

      result["errors"] = (errorsResult.data || []).map(
        (row: JSONObject): JSONObject => {
          return {
            name: String(row["name"]),
            code: toNumberOrNull(row["code"]),
            count: toNumberOrNull(row["count"]),
            lastErrorTime: toIsoOrNull(row["last_error_time"]),
            lastErrorMessage: row["last_error_message"]
              ? scrubSecretsFromText(String(row["last_error_message"]))
              : null,
          };
        },
      );
    } catch (err) {
      logger.debug("AdminHealth: system.errors unavailable");
      logger.debug(err);
    }

    // system.text_log — recent server log lines (Warning and above).
    try {
      const textLogResult: ClickhouseJsonResult = (await (
        await client.query({
          query:
            "SELECT toString(event_time) AS event_time, level, logger_name, substring(message, 1, 1000) AS message FROM system.text_log WHERE level IN ('Fatal','Critical','Error','Warning') ORDER BY event_time DESC LIMIT 200" +
            CH_DIAG_QUERY_SETTINGS,
          format: "JSON",
        })