阿里云國際站經銷商,主營阿里云,騰訊云,華為云,亞馬遜aws,谷歌云gcp,微軟云az,免費開戶,代充值優惠大,聯系客服飛機@jkkddd

通過Logstash將RDS MySQL數據同步至Elasticsearch
背景信息阿里云Logstash是一款強大的數據收集和處理工具,提供了數據采集、轉換、優化和輸出的能力。通過Logstash的logstash-input-jdbc插件(默認已安裝,不可卸載),可批量查詢RDS MySQL中的數據并同步到Elasticsearch中。同時,logstash-input-jdbc插件會定期對RDS中的數據進行輪詢查詢,并將自上次輪詢以來插入或更改的記錄同步到Elasticsearch。更多詳細信息,請參見官方文檔中的如何使用Logstash和JDBC確保Elasticsearch與關系型數據庫保持同步。本方案適用于同步全量數據且接受秒級延遲的場景或批量查詢特定條件的數據然后進行同步的場景。
操作步驟
步驟一:環境準備
在云阿里Elasticsearch實例中開啟自動創建索引功能。具體操作,請參見快速訪問與配置。
在Logstash實例中上傳與RDS MySQL版本兼容的SQL JDBC驅動(本文使用mysql-connector-java-5.1.48.jar)。具體操作,請參見配置擴展文件。
準備測試數據,并在RDS MySQL的白名單中加入阿里云Logstash節點的IP地址(可在基本信息頁面獲取)。本文使用的建表語句如下。
步驟二:配置Logstash管道
進入阿里云Elasticsearch控制臺的Logstash頁面。
進入目標實例。
在頂部菜單欄處,選擇地域。
在Logstash實例中單擊目標實例ID。
在左側導航欄,單擊管道管理。
單擊創建管道。
在創建管道任務頁面,輸入管道ID,并進行Config配置。
本文使用的Config配置如下。
單擊保存或者保存并部署。
保存:將管道信息保存在Logstash里并觸發實例變更,配置不會生效。保存后,系統會返回管道管理頁面。可在管道列表區域,單擊操作列下的立即部署,觸發實例重啟,使配置生效。
保存并部署:保存并且部署后,會觸發實例重啟,使配置生效。
步驟三:驗證結果
登錄目標阿里云Elasticsearch實例的Kibana控制臺,根據頁面提示進入Kibana主頁。
登錄Kibana控制臺的具體操作,請參見登錄Kibana控制臺。
單擊右上角的Dev tools。
在Console中,執行如下命令,查看同步成功的索引數量。
更新MySQL表數據并插入表數據。
在Kibana控制臺,查看更新后的數據。
查詢name為Chocolates的數據。
溫馨提示:尊敬的[]站點管理員,將本頁鏈接加入您的網站友情鏈接,下次可以快速來到這里更新您的站點信息哦!每天更新您的[阿里云國際賬號購買,24h小時自助充值]站點信息,可以排到首頁最前端的位置,讓更多人看到您的網站信息哦。
將以下代碼插入您網頁中,讓網友幫您更新網站每日SEO綜合情況
-
sn是什么意思_sn是什么意思啊數學 -
什么是SN? SN是一個常見的數學術語,它代表了一個序列中的第n個數字。在數學中,序列是一系列按照特定規律排列的數字。當我們需要特定的數字時,我們可以使用SN來表示。 如何計
-
深圳押車貸款 銀行汽車抵押貸款 -
深圳押車貸款,銀行汽車抵押貸款聯系:13530875815,深圳汽車抵押貸款,深圳車抵貸短期周轉,專業辦理深圳押證不押車貸款,深圳車輛抵押貸款,深圳按揭車貸款,深圳車貸,深圳車抵
-
金山研修班學歷 -
國際阿里云分銷商 金山研修班學歷學位、《廣西區內地方及農村中學研修班學員、房地產(E稱中國中醫業)研修班學員、共45人,研修班結業生達到451次、共672人,研修班學員率達到45.82、研
-
seo黑帽聯盟app運營(seo黑帽論壇) -
代理王 seo黑帽聯盟app運營與方法有哪些2. 白帽SEO免費的seo網站優化軟件3. seo黑帽seo怎么做4. 白帽SEO與黑帽seo互幫互助白帽SEO互幫互助白帽SEO,是一個專注于白帽seo快速提升排名的行seo公
-
探美族健康瘦身小知識:如何緩解口臭? -
世界上最遙遠的距離,不是我愛你,而是我站在你面前,你卻發現我——有口臭! 為什么早上起床后口中的味道會更大,一起來看看解決方法吧! 1、睡前刷牙、清潔舌苔 如果你在睡覺
-
seo軟件的找上海百首網絡(上海優質網站seo有哪些) -
防靜電推車 seo軟件的找上海百首網絡(優質網站seo有哪些)。 杭州百首網絡(優質網站seo有哪些)介紹網站:1、常州分公司是中國 域名注冊商,注冊資金30億元。公司現有近百名專利代理商、
