建站
咨詢
售后
建站咨詢
新聞中心
在今天的數(shù)據驅動的時代，數(shù)據的管理和處理變得越來越重要，因為數(shù)據是現(xiàn)代企業(yè)成功的關鍵。因此，越來越多的企業(yè)傾向于使用數(shù)據庫來存儲和管理其業(yè)務數(shù)據。然而，隨著業(yè)務的發(fā)展，這些數(shù)據庫存儲的數(shù)據數(shù)量也變得越來越龐大，以至于傳統(tǒng)的數(shù)據庫管理方法已經無法滿足大規(guī)模數(shù)據的存儲和管理需求。這時，NoSQL數(shù)據庫的出現(xiàn)成為了一個非常有效的解決方案。MongoDB是一種流行的NoSQL數(shù)據庫，其具有高可擴展性、高性能和良好的數(shù)據處理能力。因此，我們可以考慮將企業(yè)中的傳統(tǒng)數(shù)據庫同步到MongoDB，以減輕傳統(tǒng)數(shù)據庫的壓力，并更好地管理業(yè)務數(shù)據。
創(chuàng)新互聯(lián)公司成立十多年來，這條路我們正越走越好，積累了技術與客戶資源，形成了良好的口碑。為客戶提供成都網站設計、網站建設、網站策劃、網頁設計、域名申請、網絡營銷、VI設計、網站改版、漏洞修補等服務。網站是否美觀、功能強大、用戶體驗好、性價比高、打開快等等，這些對于網站建設都非常重要，創(chuàng)新互聯(lián)公司通過對建站技術性的掌握、對創(chuàng)意設計的研究為客戶提供一站式互聯(lián)網解決方案，攜手廣大客戶，共同發(fā)展進步。
本文將介紹如何實現(xiàn)數(shù)據庫同步到MongoDB。人們可以使用不同的技術和工具來實現(xiàn)這個過程，本文將著重介紹其中更流行的技術和工具，包括MongoDB的兩種驅動程序、Kafka、Flume和Logstash等。
一、使用MongoDB驅動程序
一個直接的方法是使用MongoDB的驅動程序去從傳統(tǒng)數(shù)據庫中獲取數(shù)據并將其同步到MongoDB中。MongoDB支持多種語言，包括Java、C++、Python等，因此我們可以使用適合自己編程的語言去實現(xiàn)驅動程序。
1. Java 驅動程序
如果您在使用Java編程語言，則您可以使用Java驅動程序。需要下載MongoDB驅動程序，并將其配置到Java類路徑中。一旦配置完成，就可以使用以下代碼從傳統(tǒng)數(shù)據庫中獲取數(shù)據并將其同步到MongoDB中：
“`
import com.mongodb.MongoClient;
import com.mongodb.client.MongoDatabase;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import org.bson.Document;
public class SyncData {
public static void mn( String args[] ) {
//Connect MongoDB
MongoClient mongoClient = new MongoClient( “l(fā)ocalhost” , 27017 );
//Connect traditional database
Connection connection = DriverManager.getConnection(“url”, “username”, “password”);
//Query data from traditional database
Statement stmt = connection.createStatement();
String sql = “SELECT * FROM table_name”;
ResultSet rs = stmt.executeQuery(sql);
//Insert the queried data to MongoDB
MongoDatabase db = mongoClient.getDatabase(“database_name”);
while (rs.next()) {
Document document = new Document();
document.put(“column_1”, rs.getString(“column_1”));
document.put(“column_2”, rs.getString(“column_2”));
db.getCollection(“collection_name”).insertOne(document);
}
//Close resources
rs.close();
stmt.close();
connection.close();
}
}
“`
2. Python 驅動程序
如果您在使用Python編程語言，則您可以使用Python驅動程序。需要下載Python驅動程序，并將其安裝到Python環(huán)境中。一旦安裝完成，就可以使用以下代碼從傳統(tǒng)數(shù)據庫中獲取數(shù)據并將其同步到MongoDB中：
“`
from pymongo import MongoClient
import pymysql
import pymongo
# Connect MongoDB
client = MongoClient(‘localhost’, 27017)
# Connect traditional database
conn = pymysql.connect(host=’hostname’, user=’username’, password=’password’, db=’database_name’)
cursor = conn.cursor()
# Query data from traditional database
cursor.execute(‘SELECT * FROM table_name’)
results = cursor.fetchall()
# Insert the queried data to MongoDB
db = client[‘database_name’]
collection = db[‘collection_name’]
for row in results:
data_dict = {}
data_dict[‘column_1’] = row[0]
data_dict[‘column_2’] = row[1]
collection.insert_one(data_dict)
# Close resources
cursor.close()
conn.close()
“`
二、使用數(shù)據管道
使用驅動程序是一種直接的方式，但對于大規(guī)模數(shù)據同步和處理，常常需要使用數(shù)據管道。數(shù)據管道可以將源數(shù)據流水上傳輸?shù)侥繕藬?shù)據中。本文將介紹幾個常見的數(shù)據管道，以幫助讀者了解如何實現(xiàn)數(shù)據庫同步到MongoDB。
1. 使用Kafka
Kafka是一個分布式的流數(shù)據平臺，最初由LinkedIn開發(fā)。它支持數(shù)據管道，可以將大規(guī)模的數(shù)據從源系統(tǒng)發(fā)送到目標系統(tǒng)。Kafka采用發(fā)布-訂閱模式，可以緩解數(shù)據流的壓力并提高數(shù)據處理的吞吐量。
為了將數(shù)據從傳統(tǒng)數(shù)據庫同步到MongoDB中，我們需要以下步驟：
– 從傳統(tǒng)數(shù)據庫中獲取數(shù)據流。
– 將數(shù)據寫入Kafka topic中。
– 使用Kafka Connect將數(shù)據流中的數(shù)據傳輸?shù)組ongoDB中。
2. 使用Flume
Flume是Apache的一個分布式、可靠的、可用于處理海量數(shù)據的數(shù)據管理系統(tǒng)。它可以處理、聚合和傳輸大量數(shù)據。使用Flume將數(shù)據從傳統(tǒng)數(shù)據庫同步到MongoDB中，我們需要以下步驟：
– 從傳統(tǒng)數(shù)據庫中獲取數(shù)據流。
– 將數(shù)據寫入Flume channel中。
– 將Flume channel中的數(shù)據傳輸?shù)組ongoDB中。
3. 使用Logstash
Logstash是一個開源工具，用于收集、聚合和傳輸數(shù)據從各種位置。它可以從傳統(tǒng)數(shù)據庫中收集數(shù)據并將其傳輸?shù)組ongoDB中。使用Logstash將數(shù)據從傳統(tǒng)數(shù)據庫同步到MongoDB中，我們需要以下步驟：
– 使用JDBC插件連接傳統(tǒng)數(shù)據庫。
– 配置Elasticsearch輸出插件以將數(shù)據傳輸?shù)組ongoDB中。
本文介紹了如何將傳統(tǒng)數(shù)據庫同步到MongoDB中。我們可以使用MongoDB的驅動程序或者數(shù)據管道，包括Kafka，F(xiàn)lume和Logstash等，來實現(xiàn)這個過程。對于大規(guī)模數(shù)據同步和處理，常常需要使用數(shù)據管道。它們可以將源數(shù)據流水上傳輸?shù)侥繕藬?shù)據中，緩解數(shù)據流的壓力并提高數(shù)據處理的吞吐量。本文將幫助讀者更好地理解如何實現(xiàn)數(shù)據庫同步到MongoDB，并為互聯(lián)網+、大數(shù)據等領域的開發(fā)者提供有益的參考。
成都網站建設公司-創(chuàng)新互聯(lián),建站經驗豐富以策略為先導10多年以來專注數(shù)字化網站建設,提供企業(yè)網站建設,高端網站設計,響應式網站制作,設計師量身打造品牌風格,熱線:028-86922220怎么實現(xiàn)兩個數(shù)據庫的同步
問題一定要描述具體一些，數(shù)據庫種類那么多，數(shù)據同步，隨便一列都一堆：
1、MySQL同步數(shù)據到Oracle
2、MySQL同步數(shù)據到PostgreSQL
3、MySQL同步數(shù)據到SQL Server
4、MySQL同步數(shù)據到MongoDB
5、MySQL同步數(shù)據到DB2
6、Oracle同步數(shù)據到MySQL
7、Oracle同步數(shù)據到PostgreSQL
8、Oracle同步數(shù)據到SQL Server
9、Oracle同步數(shù)據到MongoDB
10、Oracle同步數(shù)據到孝掘DB2
11、SQL Server同步數(shù)據巧昌核到MySQL
12、SQL Server同步數(shù)據到Oracle
13、SQL Server同步數(shù)據到PostgreSQL
14、SQL Server同步數(shù)據到DB2
15、……
如果僅僅是數(shù)據匯聚方迅稿面的數(shù)據同步，可以用TreeSoft ，其他還有阿里的DataX等。
同步兩個SQLServer數(shù)據庫
如何同步兩個sqlserver數(shù)據庫的內容?程序代碼可以有版本管理cvs進行同步管理,可是數(shù)據庫同步就非常麻煩,只能自己改了一個后再去改另一個,如果忘記了更改另一個經常造成兩個數(shù)據庫的結構或內容上不一致.各位有什么好的方法嗎?
一、分發(fā)與復制
用強制訂閱實現(xiàn)數(shù)據庫同步操作. 大量和批量的數(shù)據可以用數(shù)據庫的同步機制處理:
//
說明：
為方便操作,所有操作均在發(fā)布服務器(分發(fā)服務器)上操作,并使用推模式
在客戶機器使用強制訂閱方式。
二、測試通過
1:環(huán)境
服務器環(huán)境:
機器名稱： zehuadb
操作系統(tǒng)：windows 2023 server
數(shù)據庫版本：sql 2023 server 個人版
客戶端
機器名稱：zlp
操作系統(tǒng)：windows 2023 server
數(shù)據庫版本：sql 2023 server 個人版
2:建用戶帳號
在服務器端建立域用戶帳號
我的電腦管理->本地用戶和組->用戶->建立
username:zlp
userpwd:zlp
3:重新啟動服務器mssqlserver
我的電腦->控制面版->管理工具->服務->mssqlserver 服務
(更改為：域用戶帳號,我們新建的zlp用戶 .\zlp,密碼:zlp)
4:安裝分發(fā)服務器
a:配置分發(fā)服務器
工具->復制->配置發(fā)布、訂閱服務器和分發(fā)->下一步->下一步(所有的均采用默認配置)
b:配置發(fā)布服務器
工具->復制->創(chuàng)建和管理發(fā)布->選擇要發(fā)布的數(shù)據庫(sz)->下一步->
快照
發(fā)布->下一步->選擇要發(fā)布的內容->下一步->下一步->下一步->完成
c:強制配置訂閱服務器(推模式,拉模式與此雷同)
工具->復制->配置發(fā)布、訂閱服務器和分發(fā)->訂閱服務器->新建->
sql server
數(shù)據庫->輸入客戶端服務器名稱(zlp)->使用sql server 身份驗證(sa,空密碼)->確定->應用->確定
d:初始化訂閱
復制監(jiān)視器->發(fā)布服務器(zehuadb)->雙擊訂閱->強制新建->下一步->選擇啟用的訂閱服務器->zlp->下一步->下一步->下一步->下一步->完成
5:測試配置是否成功
復制監(jiān)視器->發(fā)布衿?zehuadb)->雙擊sz:sz->點狀態(tài)->點立即運行代理程序
查看：
復制監(jiān)視器->發(fā)布服務器(zehuadb)->sz:sz->選擇zlp:sz(類型強制)->鼠標右鍵->啟動同步處理
如果沒有錯誤歲毀數(shù)標志(紅色叉)，恭喜您配置成功
6:測試數(shù)據
在服務器執(zhí)行:
選擇一個表，執(zhí)行如下sql:insert into wq_newsgroup_s select ‘測試成功’乎首,5
復制監(jiān)視器->發(fā)布服務余斗器(zehuadb)->sz:sz->快照->啟動代理程序 ->zlp:sz(強制)->啟動同步處理
去查看同步的 wq_newsgroup_s 是否插入了一條新的記錄
測試完畢，通過。
7:修改數(shù)據庫的同步時間,一般選擇夜晚執(zhí)行數(shù)據庫同步處理
(具體操作略) :d
/*
注意說明：
服務器一端不能以(local)進行數(shù)據的發(fā)布與分發(fā),需要先刪除注冊，然后新建注冊本地計算機名稱
卸載方式：工具->復制->禁止發(fā)布->是在”zehuadb”上靜止發(fā)布,卸載所有的數(shù)據庫同步配置服務器
注意：發(fā)布服務器、分發(fā)服務器中的sqlserveragent服務必須啟動
采用推模式: “d:\microsoft sql server\mssql\repldata\unc” 目錄文件可以不設置共享
拉模式:則需要共享~!
*/
少量數(shù)據庫同步可以采用
觸發(fā)器
實現(xiàn),同步單表即可。
三、配置過程中可能出現(xiàn)的問題
在sql server 2023里設置和使用數(shù)據庫復制之前，應先檢查相關的幾臺sql server服務器下面幾點是否滿足：
1、mssqlserver和sqlserveragent服務是否是以域用戶身份啟動并運行的（.\administrator用戶也是可以的）
如果登錄用的是本地系統(tǒng)帳戶local，將不具備網絡功能，會產生以下錯誤:
進程未能連接到distributor ‘@server name’
(如果您的服務器已經用了sql server全文檢索服務, 請不要修改mssqlserver和sqlserveragent服務的local啟動。
會照成全文檢索服務不能用。請換另外一臺機器來做sql server 2023里復制中的分發(fā)服務器。)
修改服務啟動的登錄用戶，需要重新啟動mssqlserver和sqlserveragent服務才能生效。
2、檢查相關的幾臺sql server服務器是否改過名稱(需要srvid=0的本地機器上srvname和datasource一樣)
在查詢分析器里執(zhí)行:
use master
select srvid,srvname,datasource from sysservers
如果沒有srvid=0或者srvid=0（也就是本機器）但srvname和datasource不一樣, 需要按如下方法修改:
use master
go
— 設置兩個變量
declare @serverproperty_servername varchar(100),
@servername varchar(100)
— 取得windows nt 服務器和與指定的 sql server 實例關聯(lián)的實例信息
select @serverproperty_servername = convert(varchar(100), serverproperty(‘servername’))
— 返回運行 microsoft sql server 的本地服務器名稱
select @servername = convert(varchar(100), @@servername)
— 顯示獲取的這兩個參數(shù)
select @serverproperty_servername,@servername
–如果@serverproperty_servername和@servername不同(因為你改過計算機名字),再運行下面的
–刪除錯誤的服務器名
exec sp_dropserver @server=@servername
–添加正確的服務器名
exec sp_addserver @server=@serverproperty_servername, @local=’local’
修改這項參數(shù)，需要重新啟動mssqlserver和sqlserveragent服務才能生效。
這樣一來就不會在創(chuàng)建復制的過程中出現(xiàn)18482、18483錯誤了。
3、檢查sql server企業(yè)管理器里面相關的幾臺sql server注冊名是否和上面第二點里介紹的srvname一樣
不能用ip地址的注冊名。
（我們可以刪掉ip地址的注冊，新建以sql server管理員級別的用戶注冊的服務器名）
這樣一來就不會在創(chuàng)建復制的過程中出現(xiàn)14010、20234、18456、18482、18483錯誤了。
4、檢查相關的幾臺sql server服務器網絡是否能夠正常訪問
如果ping主機ip地址可以，但ping主機名不通的時候，需要在
winnt\system32\drivers\etc\hosts (win2023)
windows\system32\drivers\etc\hosts (win2023)
文件里寫入數(shù)據庫服務器ip地址和主機名的對應關系。
例如：
127.0.0.localhost
192.168.0.35 oracledb oracledb
192.168.0.65 fengyu02 fengyu02
202.84.10.193 bj_dbbj_db
或者在sql server客戶端網絡實用工具里建立別名，例如:
5、系統(tǒng)需要的擴展
存儲過程
是否存在(如果不存在，需要恢復):
sp_addextendedproc ‘xp_regenumvalues’,@dllname =’xpstar.dll’
go
sp_addextendedproc ‘xp_regdeletevalue’,@dllname =’xpstar.dll’
go
sp_addextendedproc ‘xp_regdeletekey’,@dllname =’xpstar.dll’
go
sp_addextendedproc xp_cmdshell ,@dllname =’xplog70.dll’
接下來就可以用sql server企業(yè)管理器里-> 右鍵選擇 ->的圖形界面來配置數(shù)據庫復制了。
下面是按順序列出配置復制的步驟:
1、建立發(fā)布和分發(fā)服務器
->->
->
文件夾
>-> -> ->
上述步驟完成后, 會在當前”@servername” sql server數(shù)據庫里建立了一個distribion庫和 一個distributor_admin管理員級別的用戶(我們可以任意修改密碼)。
服務器上新增加了四個作業(yè):
sql server企業(yè)管理器里多了一個復制監(jiān)視器, 當前的這臺機器就可以發(fā)布、分發(fā)、訂閱了。
我們再次在sql server企業(yè)管理器里-> 右鍵選擇 ->
我們可以在 窗口-> -> -> -> -> / -> -> -> ->
把網絡上的其它sql server服務器添加成為發(fā)布或者訂閱服務器.
新增一臺發(fā)布服務器的選項：
我這里新建立的jin001發(fā)布服務器是用管理員級別的數(shù)據庫用戶test連接的，
到發(fā)布服務器的管理鏈接要輸入密碼的可選框, 默認的是選中的，
在新建的jin001發(fā)布服務器上建立和分發(fā)服務器fengyu/fengyu的鏈接的時需要輸入distributor_admin用戶的密碼。到發(fā)布服務器的管理鏈接要輸入密碼的可選框，也可以不選，也就是不需要密碼來建立發(fā)布到分發(fā)服務器的鏈接(這當然欠缺安全，在測試環(huán)境下可以使用)。
2、新建立的網絡上另一臺發(fā)布服務器(例如jin001)選擇分發(fā)服務器
->
-> 使用下列服務器(選定的服務器必須已配置為分發(fā)服務器) -> (例如fengyu/fengyu)
-> ->
-> -> ->
-> -> ->
建立一個數(shù)據庫復制發(fā)布的過程:
-> -> 右鍵選擇 ->
-> -> ->
-> -> -> /
-> -> ->
-> -> -> ->
->,默認值是newid()>
(添加新列將: 導致不帶列列表的 insert 語句失敗,增加表的大小,增加生成之一個快照所要求的時間)
->
-> -> ->
-> -> ->
-> -> ->
發(fā)布屬性里有很多有用的選項：設定訂閱到期(例如24小時)
設定發(fā)布表的項目屬性:
常規(guī)窗口可以指定發(fā)布目的表的名稱，可以跟原來的表名稱不一樣。
下圖是命令和快照窗口的欄目
( sql server 數(shù)據庫復制技術實際上是用insert,update,delete操作在訂閱服務器上重做發(fā)布服務器上的事務操作
看文檔資料需要把發(fā)布數(shù)據庫設成完全恢復模式，事務才不會丟失
但我自己在測試中發(fā)現(xiàn)發(fā)布數(shù)據庫是簡單恢復模式下，每10秒生成一些大事務，10分鐘后再收縮數(shù)據庫日志，
這期間發(fā)布和訂閱服務器上的作業(yè)都暫停，暫?；謴秃蟛]有丟失任何事務更改 )
發(fā)布表可以做數(shù)據篩選，例如只選擇表里面的部分列:
例如只選擇表里某些符合條件的記錄, 我們可以手工編寫篩選的sql語句:
發(fā)布表的訂閱選項，并可以建立強制訂閱:
成功建立了發(fā)布以后,發(fā)布服務器上新增加了一個作業(yè):
分發(fā)服務器上新增加了兩個作業(yè):
類型
類型
上面藍色字的名稱會根據發(fā)布服務器名,發(fā)布名及第幾次發(fā)布而使用不同的編號
repl快照作業(yè)是sql server復制的前提條件,它會先把發(fā)布的表結構,數(shù)據,索引,約束等生成到發(fā)布服務器的os目錄下文件
(當有訂閱的時候才會生成, 當訂閱請求初始化或者按照某個時間表調度生成)
repl日志讀取器在事務復制的時候是一直處于運行狀態(tài)。(在合并復制的時候可以根據調度的時間表來運行)
建立一個數(shù)據庫復制訂閱的過程:
-> -> 右鍵選擇 ->
-> -> ->
-> -> ->
-> -> ->
(輸入發(fā)布服務器上distributor_admin用戶名和密碼)
-> -> -> /
-> -> ->
-> -> ->
-> -> ->
(訂閱服務器要能訪問發(fā)布服務器的repldata文件夾，如果有問題，可以手工設置網絡共享及共享權限)
-> -> ->
-> -> -> -> ->
-> -> ->
-> -> ->
成功建立了訂閱后，訂閱服務器上新增加了一個類別是作業(yè)(合并復制的時候類別是)
它會按照我們給的時間調度表運行數(shù)據庫同步復制的作業(yè)。
3、sql server復制配置好后, 可能出現(xiàn)異常情況的實驗日志:
1.發(fā)布服務器斷網,sql server服務關閉,重啟動,關機的時候,對已經設置好的復制沒有多大影響
中斷期間,分發(fā)和訂閱都接收到沒有復制的事務信息
2.分發(fā)服務器斷網,sql server服務關閉,重啟動,關機的時候,對已經設置好的復制有一些影響
中斷期間,發(fā)布服務器的事務排隊堆積起來
(如果設置了較長時間才刪除過期訂閱的選項, 繁忙發(fā)布數(shù)據庫的事務日志可能會較快速膨脹),
訂閱服務器會因為訪問不到發(fā)布服務器,反復重試
我們可以設置重試次數(shù)和重試的時間間隔(更大的重試次數(shù)是9999, 如果每分鐘重試一次,可以支持約6.9天不出錯)
分發(fā)服務器sql server服務啟動,網絡接通以后,發(fā)布服務器上的堆積作業(yè)將按時間順序作用到訂閱機器上:
會需要一個比較長的時間(實際上是生成所有事務的insert,update,delete語句,在訂閱服務器上去執(zhí)行)
我們在普通的pc機上實驗的58個事務100228個命令執(zhí)行花了7分28秒.
3.訂閱服務器斷網,sql server服務關閉,重啟動,關機的時候,對已經設置好的復制影響比較大,可能需要重新初試化
我們實驗環(huán)境(訂閱服務器)從18:46分意外停機以, 第二天8:40分重啟動后, 已經設好的復制在8:40分以后又開始正常運行了, 發(fā)布服務器上的堆積作業(yè)將按時間順序作用到訂閱機器上, 但復制管理器里出現(xiàn)快照的錯誤提示, 快照可能需要重新初試化,復制可能需要重新啟動.(我們實驗環(huán)境的機器并沒有進行快照初試化,復制仍然是成功運行的)
4、刪除已經建好的發(fā)布和定閱可以直接用delete刪除按鈕
我們更好總是按先刪定閱，再刪發(fā)布，最后禁用發(fā)布的順序來操作。
如果要徹底刪去sql server上面的復制設置, 可以這樣操作:
-> 右鍵選擇 ->
-> -> ->
-> -> ->
我們也可以用t-sql命令來完成復制中發(fā)布及訂閱的創(chuàng)建和刪除, 選中已經設好的發(fā)布和訂閱, 按屬標右鍵可以。(這里就不詳細講了, 后面推薦的網站內有比較詳細的內容)
當你試圖刪除或者變更一個table時，出現(xiàn)以下錯誤
server: msg 3724, level 16, state 2, line 1
cannot drop the table ‘object_name’ because it is being used for replication.
比較典型的情況是該table曾經用于復制，但是后來又刪除了復制。
處理辦法：
select * from sysobjects where replinfo >’0′
sp_configure ‘allow updates’, 1
go
reconfigure with override
go
begin transaction
update sysobjects set replinfo = ‘0’ where replinfo >’0′
commit transaction
go
rollback transaction
go
sp_configure ‘allow updates’, 0
go
reconfigure with override
go
實現(xiàn)兩個數(shù)據庫
同構同步
： 屬于數(shù)據庫復制同步工具 （
如甲骨文OGG/北京靈蜂Beedup
)
單向同粗閉雀步 如 SQLServer A 到SQLServer B（SQLServer自帶僅適用于自身）
雙向同步 如 SQLServer A 到 SQLServer B / SQLServer B 再到SQLServer A （SQLServer自帶未有）
實現(xiàn)兩個數(shù)據庫
異構同步
：屬于ETL轉換工具巖早范疇（
如 Informatica / Beeload/BeeDI
)
單向同步 如Oracle 到 SQL Server ……
如何將wireshark抓包的網絡數(shù)據流數(shù)據存入到mongodb數(shù)據庫中
定時生成文本文件，直接存入mongo
MongoDB是一個面向文檔的數(shù)據庫，目前由10gen開發(fā)并維護，它的功能豐富，齊全，所以完全可以替代MySQL。
與MySQL等關系型數(shù)據庫相比，MongoDB的優(yōu)點如下：
?、偃跻恢滦?，更能保證用戶的訪問速度。
?、谖臋n結構的存儲方式，能夠更便捷的獲取數(shù)據。
③內置GridFS，支持大容量的存儲。
?、軆戎肧harding。
?、莸谌街С重S富。慎凳(這是與其他寬羨旅的NoSQL相比，MongoDB也具有派孝的優(yōu)勢)
?、扌阅軆?yōu)越：
單機mongodb數(shù)據庫怎么導入分片集群中
準備工作：在導入數(shù)據前，先配置好要分片的數(shù)據庫及表。
不然導入完成后，發(fā)現(xiàn)數(shù)據庫，表沒有同步到另外一個集群。
我這里做了從原單機數(shù)據庫數(shù)據導出后，再分片集群庫中導入操作握并。
當設置了要分段隱跡片的庫，及表后，系統(tǒng)會自動幫你添加庫及表。
設置完成后，就可以導入數(shù)據了。
use admin
db.runCommand({enablesharding:”ip”})
db.runCommand({shardcollection:”ip.ipaddress”,key:{ip1:1}})
./mongorestore -h 192.168.20.11 –portd ip /opt/攜肢backup/ip/ip
./mongorestore -h 192.168.20.11 –portd dmp /opt/backup/dmp/dmp
1. 導出需要遷移的數(shù)據；
/usr/local/mongo/bin/mongodump –host 172.16.8.134:d 201 -o /data/data/mongo/tmp/ –directoryperdb
并且將該數(shù)據同步到131的/慧禪遲data/data/mongodb/tmp目錄中
2. 建立之一個副本集
2.1 建立之一個襲銀副本集前李shard1，不帶分片的
server1:
/usr/local/mongo/bin/mongod –replSet shard1 –portdbpath=/data/data/mongodb/shard11 –logpath=/data/log/shard11.log –logappend –fork
server2:
/usr/local/mongo/bin/mongod –replSet shard1 –portdbpath=/data/data/mongodb/shard12 –logpath=/data/log/shard12.log –logappend –fork
server3:
/usr/local/mongo/bin/mongod –replSet shard1 –portdbpath=/data/data/mongodb/shard13 –logpath=/data/log/shard13.log –logappend –fork
2.2 初始化之一個副本集shard1
./mongo –port 29017
config={_id : ‘shard1’,members : }
rs.initiate(config)
數(shù)據庫同步到momgodb的介紹就聊到這里吧，感謝你花時間閱讀本站內容，更多關于數(shù)據庫同步到momgodb,如何實現(xiàn)數(shù)據庫同步到MongoDB？,怎么實現(xiàn)兩個數(shù)據庫的同步,如何將wireshark抓包的網絡數(shù)據流數(shù)據存入到mongodb數(shù)據庫中,單機mongodb數(shù)據庫怎么導入分片集群中的信息別忘了在本站進行查找喔。
成都創(chuàng)新互聯(lián)科技公司主營:網站設計、網站建設、小程序制作、成都軟件開發(fā)、網頁設計、微信開發(fā)、成都小程序開發(fā)、網站制作、網站開發(fā)等業(yè)務，是專業(yè)的成都做小程序公司、成都網站建設公司、成都做網站的公司。創(chuàng)新互聯(lián)公司集小程序制作創(chuàng)意，網站制作策劃，畫冊、網頁、VI設計，網站、軟件、微信、小程序開發(fā)于一體。
網站欄目：如何實現(xiàn)數(shù)據庫同步到MongoDB？(數(shù)據庫同步到momgodb)
新聞來源：http://www.dlmjj.cn/article/cdossgh.html
