MySQL 到 Elasticsearch 实时数据同步实操分享，研发人员面试笔试题

-- 假设我们有一个名为 `orders` 的 MySQL 表，我们想要实现与 Elasticsearch 的实时同步。
-- 首先，我们需要在 MySQL 中为此设置一个触发器，每当有新订单插入时，就同步更新 Elasticsearch。
 
DELIMITER $$
 
-- 创建触发器以在插入新订单时更新 Elasticsearch
CREATE TRIGGER `orders_after_insert` AFTER INSERT ON `orders` FOR EACH ROW
BEGIN
    -- 这里使用您选择的语言或库来实现与 Elasticsearch 的通信
    -- 例如，使用 Python 的 elasticsearch 库
    DECLARE es_host VARCHAR(255) DEFAULT 'localhost:9200'; -- Elasticsearch 地址
    DECLARE json_payload TEXT;
 
    SET json_payload = '{
        "order_id": NEW.id,
        "customer_name": NEW.customer_name,
        "order_date": NEW.order_date,
        "total_amount": NEW.total_amount
    }';
 
    -- 使用 MySQL 的 `system` 命令调用外部脚本或程序
    SET @cmd = CONCAT('python3 /path/to/es_sync_script.py --host=', es_host, ' --index=orders --action=index --payload="', json_payload, '"');
    PREPAREstmt FROM @cmd;
    EXECUTEstmt;
    DEALLOCATE PREPAREstmt;
END$$
 
DELIMITER ;

在这个例子中，我们创建了一个名为 orders_after_insert 的触发器，它在每次向 orders 表插入新记录时执行。触发器内部，我们使用 MySQL 的 PREPARE 语句来调用一个外部的 Python 脚本，该脚本负责与 Elasticsearch 集群通信，实现数据同步。

注意：实际使用时，需要替换 /path/to/es_sync_script.py 为实际的脚本路径，并确保该脚本具有执行权限，且能够正确与 Elasticsearch 集群通信。此外，Elasticsearch 的地址 (es_host) 和索引配置 ("orders") 也需要根据实际情况进行相应的调整。