es拉取mysql的增量更新代碼_MySQL
來(lái)源:懂視網(wǎng)
責(zé)編:小采
時(shí)間:2020-11-09 19:24:58
es拉取mysql的增量更新代碼_MySQL
es拉取mysql的增量更新代碼_MySQL:基于開(kāi)源插件。具體可參考http://my.oschina.net/qiangzigege/blog/220224 ~~~~~~ 目的:實(shí)現(xiàn)增量更新 原理 1)第一次全量更新,更新完畢后,刪除這個(gè)任務(wù)。 2)發(fā)布增量更新任務(wù)即可。 ~~~~~~~~~ 增量更新任務(wù)的模板如下:
導(dǎo)讀es拉取mysql的增量更新代碼_MySQL:基于開(kāi)源插件。具體可參考http://my.oschina.net/qiangzigege/blog/220224 ~~~~~~ 目的:實(shí)現(xiàn)增量更新 原理 1)第一次全量更新,更新完畢后,刪除這個(gè)任務(wù)。 2)發(fā)布增量更新任務(wù)即可。 ~~~~~~~~~ 增量更新任務(wù)的模板如下:

基于開(kāi)源插件。具體可參考http://my.oschina.net/qiangzigege/blog/220224
~~~~~~
目的:實(shí)現(xiàn)增量更新
原理
1)第一次全量更新,更新完畢后,刪除這個(gè)任務(wù)。
2)發(fā)布增量更新任務(wù)即可。
~~~~~~~~~
增量更新任務(wù)的模板如下:
curl -XPUT 'ip:9200/_river/my_jdbc_river/_meta' -d '{"type":"jdbc","jdbc":{"url":"jdbc:mysql://IP:3306/fastooth","user":"dewmobile","password":"dewmobile","sql":"select * from users where updated_at between UNIX_TIMESTAMP(now())*1000-60000 86400000 and UNIX_TIMESTAMP(now())*1000 or created_at between UNIX_TIMESTAMP(now())*1000-60000 86400000 and UNIX_TIMESTAMP(now())*1000","schedule":"0 0-59 0-23 * * ?","index":"ccc","type":"ddd"}}'
聲明:本網(wǎng)頁(yè)內(nèi)容旨在傳播知識(shí),若有侵權(quán)等問(wèn)題請(qǐng)及時(shí)與本網(wǎng)聯(lián)系,我們將在第一時(shí)間刪除處理。TEL:177 7030 7066 E-MAIL:11247931@qq.com
es拉取mysql的增量更新代碼_MySQL
es拉取mysql的增量更新代碼_MySQL:基于開(kāi)源插件。具體可參考http://my.oschina.net/qiangzigege/blog/220224 ~~~~~~ 目的:實(shí)現(xiàn)增量更新 原理 1)第一次全量更新,更新完畢后,刪除這個(gè)任務(wù)。 2)發(fā)布增量更新任務(wù)即可。 ~~~~~~~~~ 增量更新任務(wù)的模板如下: