jq监听数据库

CREATE OR REPLACE FUNCTION notify_trigger() RETURNS TRIGGER AS $$
BEGIN
    PERFORM pg_notify('channel_name', NEW.json_data::text);
    RETURN NEW;
END;
$$ LANGUAGE plpgsql;

CREATE TRIGGER my_trigger
AFTER INSERT OR UPDATE ON my_table
FOR EACH ROW EXECUTE FUNCTION notify_trigger();

#!/bin/bash

while true; do
    psql -c "LISTEN channel_name;" -d my_database | while read -r notification; do
        echo "Received notification: $notification"
        # 使用 jq 处理新数据
        jq '.key' <<< "$notification"
    done
done

#!/bin/bash

while true; do
    # 查询数据库获取最新数据
    new_data=$(psql -d my_database -c "SELECT json_data FROM my_table ORDER BY id DESC LIMIT 1")
    
    # 使用 jq 处理新数据
    processed_data=$(echo "$new_data" | jq '.key')
    
    # 处理 processed_data
    echo "Processed data: $processed"
    
    # 等待一段时间后再次查询
    sleep 10
done