重要前提
安装AI Skills的关键前提是:必须科学上网,且开启TUN模式,这一点至关重要,直接决定安装能否顺利完成,在此郑重提醒三遍:科学上网,科学上网,科学上网。查看完整安装教程 →
altinity-expert-clickhouse-ingestion by altinity/skills
npx skills add https://github.com/altinity/skills --skill altinity-expert-clickhouse-ingestion运行 checks.sql 文件中的所有查询并分析结果。
当插入操作需要更新物化视图时,缓慢的物化视图会导致插入延迟。要将一个缓慢的插入操作与其物化视图的详细分解关联起来,请使用以下查询:
-- 将缓慢的插入操作与物化视图分解关联(需要 query_id)
select
view_name,
view_duration_ms,
read_rows,
written_rows,
status
from system.query_views_log
where query_id = '{query_id}'
order by view_duration_ms desc
此查询仅用于有问题的 Kafka 表,以避免产生大量无关输出。
-- 当观察到延迟时,筛选到特定的 Kafka 表
select
hostName() as host,
database,
table,
consumer_id,
is_currently_used,
dateDiff('second', last_poll_time, now()) as last_poll_age_s,
dateDiff('second', last_commit_time, now()) as last_commit_age_s,
num_messages_read,
num_commits,
length(assignments.topic) as assigned_partitions,
length(exceptions.text) as exception_count,
exceptions.text[-1] as last_exception
from clusterAllReplicas('{cluster}', system.kafka_consumers)
where database = '{db}'
and table = '{kafka_table}'
order by is_currently_used desc, last_poll_age_s desc
limit 50
广告位招租
在这里展示您的产品或服务
触达数万 AI 开发者,精准高效
-- 始终限制结果集大小
limit 100
-- 始终限定时间范围
where event_date = today()
-- 或者
where event_time > now() - interval 1 hour
-- 对于 query_log,按类型筛选
where type = 'QueryFinish' -- 已完成的查询
-- 或者
where type like 'Exception%' -- 失败的查询
-- 按表筛选
where has(tables, 'database.table_name')
-- 按用户筛选
where user = 'producer_app'
-- 按插入数据量筛选
where written_rows > 1000000 -- 大批量插入
where written_rows < 100 -- 微批量插入
每周安装量
46
代码仓库
GitHub 星标数
5
首次出现
2026年1月24日
安全审计
已安装于
codex44
claude-code40
gemini-cli21
opencode21
github-copilot19
kimi-cli17
Run all queries from the file checks.sql and analyze the results.
When inserts feed materialized views, slow MVs cause insert delays. To correlate a slow insert with its MV breakdown:
-- Correlate slow insert with MV breakdown (requires query_id)
select
view_name,
view_duration_ms,
read_rows,
written_rows,
status
from system.query_views_log
where query_id = '{query_id}'
order by view_duration_ms desc
Use this only for problematic Kafka tables to avoid noisy output.
-- Filter to a specific Kafka table when lag is observed
select
hostName() as host,
database,
table,
consumer_id,
is_currently_used,
dateDiff('second', last_poll_time, now()) as last_poll_age_s,
dateDiff('second', last_commit_time, now()) as last_commit_age_s,
num_messages_read,
num_commits,
length(assignments.topic) as assigned_partitions,
length(exceptions.text) as exception_count,
exceptions.text[-1] as last_exception
from clusterAllReplicas('{cluster}', system.kafka_consumers)
where database = '{db}'
and table = '{kafka_table}'
order by is_currently_used desc, last_poll_age_s desc
limit 50
-- Always limit results
limit 100
-- Always time-bound
where event_date = today()
-- or
where event_time > now() - interval 1 hour
-- For query_log, filter by type
where type = 'QueryFinish' -- completed
-- or
where type like 'Exception%' -- failed
-- Filter by table
where has(tables, 'database.table_name')
-- Filter by user
where user = 'producer_app'
-- Filter by insert size
where written_rows > 1000000 -- large inserts
where written_rows < 100 -- micro-batches
Weekly Installs
46
Repository
GitHub Stars
5
First Seen
Jan 24, 2026
Security Audits
Gen Agent Trust HubPassSocketPassSnykPass
Installed on
codex44
claude-code40
gemini-cli21
opencode21
github-copilot19
kimi-cli17
Vercel React 最佳实践指南 | Next.js 性能优化与代码规范
10,600 周安装
专业网页设计专家 | 品牌形象与视觉系统设计 | OKLCH配色方案与响应式设计
142 周安装
Claude.md优化指南:使用improve-claude-md提升AI代码助手效率
141 周安装
Azure Functions 无服务器计算指南:使用场景、快速开始与最佳实践
143 周安装
OKRs目标管理框架 - 产品经理必备的OKR设定与执行工具 | PMPrompt
142 周安装
PDF 提取器 - 使用 pdfplumber 从 PDF 中提取文本、表格和图像,转换为可用数据
44 周安装
负熵透镜:评估系统架构与决策的熵增/负熵思维框架 | 软件工程与系统设计
142 周安装