如果是用 Nginx 做代理，访问文件时会有 Nginx 日志，将日志入到 kafka
写个 kafka 消费者消费 Nginx 日志删除文件

go go go

你这说的应该是里面，向这样
for(...所有商户...){
write_lock(付款方,收款方)
付款方 -￥
收款方 +￥
write_unlock(付款方,收款方)
}

爱阅书香 也不错

用过 kettle 做 mysql 到 postgres 的迁移，还不错

#需要更好的#

我也鄂州的 ^_^

人满了，扫不进去

我取啦也可以 12306 退票的，深圳到武汉

limit 参数可以填无穷大

爽文，看的爽放松放松

简单点： 用`memory_limit`参数限制最大内存，monitor 挂了自动拉起
复杂点： 用`memory_get_usage`调试，看内存是啥时候起来的，排查原因

印象笔记，Typora，百度网盘

增量查询，找好递增 key 就行
1. key 要是递增
2. key 的重复记录越少越好（ id，create_time 啥的都可以）

id 的话直接每次增量 > 上次 id 查询就行（同 id 没有重复记录）
create_time 的话，要兼容重复记录的增量，程序得做下处理

试试 clock_timestamp()::TEXT

感谢楼主分享,学习学习

不错的创意

你这相当于是阻塞式的，一个 insert 完在处理下一个，没有用到并发呢。
调整下程序逻辑，可以考虑下并发 insert