MySQL触发器不能直接发HTTP或写Kafka，必须通过“写表+外部消费”解耦：触发器仅将变更写入轻量中间表notify_queue，外部程序轮询、重试、幂等投递并定期清理。
MySQL触发器里不能直接发 HTTP 或写 Kafka
直接在 AFTER INSERT 触发器里调用 curl、INSERT INTO remote_kafka_topic 或执行 SYS_EVAL，会失败或导致主库卡死。MySQL 服务进程不支持网络 I/O，也不允许跨实例写入；哪怕临时启用 UDF（如 sys_exec），也会因权限限制、云数据库禁用、无重试机制而在线上崩塌。
常见错误现象包括：ERROR 1418 (HY000)（函数未声明特性）、事务莫名回滚、下游消息重复或丢失、触发器静默不执行（查 information_schema.TRIGGERS 才发现没生效）。
必须用“写表 + 外部消费”解耦
触发器只做一件事：把变更快照快速、轻量地写进一张中间表，比如 notify_queue 或 mq_outbox。这张表结构要极简，避免 JSON 拼接、大字段和冗余索引。
id BIGINT PRIMARY KEY AUTO_INCREMENT-
table_name VARCHAR(64) NOT NULL（标识来源表） -
pk_value VARCHAR(255) NOT NULL（统一转字符串，兼容 INT/VARCHAR 主键） op_type ENUM('INSERT','UPDATE','DELETE')created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMPdelivered TINYINT DEFAULT 0
务必加联合索引：INDEX idx_delivered_created (delivered, created_at)，否则消费者 SELECT ... WHERE delivered = 0 会全表扫描。
安装、修复、更新或打包一个基于 Python 和 PyMySQL 实现的 Windows `mysql` 命令。适用于用户希望在 PowerShell/CMD 中输入 `mysql` 时重定向到 Python 实现、需要交互式输入 MySQL 连接信息、需要同步到当前用户本地 bin 目录，或需要将该能力封装成可公开复用的 Codex skill。
触发器体里只写 INSERT，别碰业务逻辑
BEFORE/AFTER 触发器中禁止做以下操作：
- 调用
JSON_OBJECT()拼整行数据（MySQL 5.7+ 在触发器中性能差，8.0 兼容性风险高） - 查其他表做判断（引发锁等待或死锁）
- 更新非目标表的冗余字段（除非确定是轻量、本地、幂等操作）
- 使用
SET @var做状态计数（变量不跨连接，不可靠）
正确写法示例（orders 表插入后记录通知）：
DELIMITER //
CREATE TRIGGER trig_order_notify AFTER INSERT ON orders
FOR EACH ROW
BEGIN
INSERT INTO notify_queue (table_name, pk_value, op_type)
VALUES ('orders', CAST(NEW.id AS CHAR), 'INSERT');
END//
DELIMITER ;
外部消费者必须自己管重试、幂等和位点
轮询脚本（Python/Go）不是“查完就删”，而是：
- 用
SELECT ... WHERE delivered = 0 ORDER BY id LIMIT 100批量拉取 - 投递成功后，用
UPDATE notify_queue SET delivered = 1 WHERE id IN (...)标记（原子操作） - 失败时保留
delivered = 0，靠下次轮询重试 - 投递前检查幂等键（如用
MD5(CONCAT(table_name, pk_value, op_type))生成唯一消息 ID）
最容易被忽略的是清理策略：不 DELETE FROM notify_queue WHERE delivered = 1 AND created_at ，表会持续膨胀，最终拖慢所有查询。
