अब MongoDB में लेनदेन कैसे महसूस करें

2018 की गर्मियों में (जो कि अभी, इस लेखन के समय) है, अविश्वसनीय रूप से हुआ - ईमानदार ACID लेनदेन को MongoDB में लाया गया। इस दस्तावेज़-उन्मुख DBMS के चौथे संस्करण की रिलीज़ के साथ, इसे थोड़ा और अधिक गंभीर अनुप्रयोगों के लिए उपयोग किया जा सकता है।

जो लोग टैंक में हैं, संक्षेप में: लेन-देन हमें कई दस्तावेजों में परिवर्तनों की एक श्रृंखला को पूरा करने और उन्हें एक ही बार में सहेजने की अनुमति देता है, या लेन-देन के भीतर किए गए सभी परिवर्तनों को उसी तरह रद्द कर देता है, अगर कुछ गलत हो गया, या आवेदन दुर्घटनाग्रस्त हो गया ।

दुर्भाग्य से, डेवलपर इस सुपर फीचर का उपयोग करना इतना आसान नहीं है। नीचे मैं आपको बताऊंगा कि क्यों, और इसके बारे में क्या करना है।

यदि हम लेन-देन अनुभाग में DBMS के लिए दस्तावेज खोलते हैं, तो हम निम्नलिखित टिप्पणी देख सकते हैं:

बहु-दस्तावेज़ लेनदेन केवल प्रतिकृति सेट के लिए उपलब्ध हैं। शार्प कलस्टर के लिए ट्रांजेक्शन MongoDB 4.2 के लिए निर्धारित हैं

यह हमें बताता है कि एक साधारण MongoDB सर्वर लेनदेन का समर्थन नहीं करता है, केवल प्रतिकृति सेट मोड में एक क्लस्टर है। शार्प्ड क्लस्टर्स के लिए सपोर्ट भी बाद में 4.2 वर्जन में आएगा।

उसी समय, एक सामान्य सर्वर हमें लेनदेन शुरू करने, उसे सहेजने, या उसे रद्द करने देगा, लेकिन इसके भीतर कुछ भी नहीं किया जा सकता है, इस तरह एक त्रुटि प्रदर्शित की जाएगी:

WriteCommandError({ "ok" : 0, "errmsg" : "Transaction numbers are only allowed on a replica set member or mongos", "code" : 20, "codeName" : "IllegalOperation" }) 

सौभाग्य से, कोई भी एकल-सर्वर MongoDB क्लस्टर चला सकता है। अपनी मशीनों पर, जिस पर मैं विकास में लगा हूं, मैं सभी DBMS को डॉकटर कंटेनरों में चलाता हूं। उदाहरण के लिए, एक नियमित MongoDB सर्वर शुरू करना इस तरह दिखता है:

 docker run -v ~/mongo/:/data/db --name mongo --restart=always -p 27017:27017 -d mongo mongod --smallfiles 

चलो स्टार्टअप कुंजियों का विश्लेषण करें:

• -v ~ / mongo /: / data / db का अर्थ है स्थानीय निर्देशिका ~ / mongo / in / data / db of कंटेनर, इसलिए डेटाबेस खुद को होस्ट मशीन पर संग्रहीत किया जाएगा, जो हमें चल रहे कंटेनर, अपडेट संस्करण आदि को हटाने की अनुमति देगा। घ। हमारे डेटा के संरक्षण के साथ;
• --name mongo कंटेनर का नाम सेट करता है;
• - श्रेष्ठ = हमेशा कहता है कि कंटेनर में किसी भी सेवा के दुर्घटनाग्रस्त होने की स्थिति में, इसे फिर से चालू किया जाना चाहिए, साथ ही ऑपरेटिंग सिस्टम को लोड करने के बाद कंटेनर को शुरू करना चाहिए;
• -पी 27017: 27017 "आगे" मेजबान मशीन के लिए बंदरगाह;
• -d इंगित करता है कि आपको एक डेमॉन के रूप में कंटेनर शुरू करने की आवश्यकता है;
• मोंगो - कंटेनर को चलाने के लिए छवि का नाम;
• mongod --smallfiles - कंटेनर में सेवा शुरू करने के लिए कमांड।

एक साधारण सर्वर कैसे शुरू करें, मैं सिर्फ संदर्भ के लिए लाया हूं। अब समझते हैं कि लेनदेन का समर्थन करने वाले सर्वर को शुरू करने के लिए क्या करना चाहिए।

सबसे पहले, आपको डॉकटर के अंदर एक नया नेटवर्क बनाना चाहिए, जिसमें हमारे क्लस्टर के सभी सर्वर काम करेंगे। हां, मैंने ऊपर लिखा है कि एक सर्वर होगा, लेकिन एक नेटवर्क बनाना होगा, अन्यथा कुछ भी नहीं चलेगा।

 docker network create mongo-cluster 

अगला, कंटेनर लॉन्च मापदंडों में, आपको नए नेटवर्क --नेट मोंगो-क्लस्टर का उपयोग निर्दिष्ट करने की आवश्यकता है, और प्रतिकृति सेट मोड में काम करने के लिए सर्वर को पैरामीटर भी पास करना होगा : --replSet rs0 । इसके अलावा, मैं जानबूझकर छोड़ा गया था - श्रेष्ठता = हमेशा स्विच करें, जैसा कि मैं इस समय हमेशा काम में MongoDB का उपयोग नहीं करता हूं और मैं नहीं चाहता कि यह ऑपरेटिंग सिस्टम के साथ शुरू हो।

 docker run -v ~/mongo/:/data/db --name mongo -p 27017:27017 -d mongo mongod --smallfiles --replSet rs0 

महान, कंटेनर चल रहा है, जैसा कि हम docker ps कमांड चलाकर देख सकते हैं और निम्नलिखित कुछ देख सकते हैं:

 docker ps CONTAINER ID IMAGE COMMAND CREATED STATUS PORTS NAMES 2292d7e0778b mongo "docker-entrypoint.s…" About a minute ago Up About a minute 0.0.0.0:27017->27017/tcp mongo 

इसके बाद, हमें क्लस्टर को इनिशियलाइज़ करने की आवश्यकता है, इसके लिए हम रनिंग सर्वर के कंसोल में जाते हैं, अपने क्लस्टर का कॉन्फ़िगरेशन बनाते हैं और इनिशियलाइज़ेशन करते हैं:

 docker exec -it mongo mongo # output omited # > config = { "_id" : "rs0", "members" : [ { "_id" : 0, "host" : "mongo:27017" } ] } > rs.initiate(config) { "ok" : 1, "operationTime" : Timestamp(1531248932, 1), "$clusterTime" : { "clusterTime" : Timestamp(1531248932, 1), "signature" : { "hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="), "keyId" : NumberLong(0) } } } rs0:SECONDARY> rs0:PRIMARY> 

हो गया! हमें एक MongoDB सर्वर से एक क्लस्टर मिला है। अब आप सत्यापित कर सकते हैं कि सब कुछ उम्मीद के मुताबिक काम कर रहा है।

 rs0:PRIMARY> session = db.getMongo().startSession() session { "id" : UUID("7eb81006-983f-4398-adc7-5ed23e027377") } rs0:PRIMARY> database = session.getDatabase("test") test rs0:PRIMARY> //    rs0:PRIMARY> database.col.insert({name: "1"}) WriteResult({ "nInserted" : 1 }) rs0:PRIMARY> database.col.insert({name: "2"}) WriteResult({ "nInserted" : 1 }) rs0:PRIMARY> database.col.insert({name: "3"}) WriteResult({ "nInserted" : 1 }) rs0:PRIMARY> database.col.insert({name: "4"}) WriteResult({ "nInserted" : 1 }) rs0:PRIMARY> // ,     rs0:PRIMARY> database.col.find({}) { "_id" : ObjectId("5b45026edc396f534f11952f"), "name" : "1" } { "_id" : ObjectId("5b450272dc396f534f119530"), "name" : "2" } { "_id" : ObjectId("5b450274dc396f534f119531"), "name" : "3" } { "_id" : ObjectId("5b450276dc396f534f119532"), "name" : "4" } rs0:PRIMARY> //   rs0:PRIMARY> session.startTransaction() rs0:PRIMARY> //    rs0:PRIMARY> database.col.update({name: "4"}, {name: "44"}) WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 }) rs0:PRIMARY> //   rs0:PRIMARY> database.col.find({}) { "_id" : ObjectId("5b45026edc396f534f11952f"), "name" : "1" } { "_id" : ObjectId("5b450272dc396f534f119530"), "name" : "2" } { "_id" : ObjectId("5b450274dc396f534f119531"), "name" : "3" } { "_id" : ObjectId("5b450276dc396f534f119532"), "name" : "44" } rs0:PRIMARY> //         ,    -: rs0:PRIMARY> // { "_id" : ObjectId("5b450276dc396f534f119532"), "name" : "4" } rs0:PRIMARY> //   rs0:PRIMARY> session.commitTransaction() rs0:PRIMARY> //   rs0:PRIMARY> database.col.find({}) { "_id" : ObjectId("5b45026edc396f534f11952f"), "name" : "1" } { "_id" : ObjectId("5b450272dc396f534f119530"), "name" : "2" } { "_id" : ObjectId("5b450274dc396f534f119531"), "name" : "3" } { "_id" : ObjectId("5b450276dc396f534f119532"), "name" : "44" } rs0:PRIMARY> //     rs0:PRIMARY> session.startTransaction() rs0:PRIMARY> database.col.update({name: "44"}, {name: "42"}) WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 }) rs0:PRIMARY> database.col.find({}) { "_id" : ObjectId("5b45026edc396f534f11952f"), "name" : "1" } { "_id" : ObjectId("5b450272dc396f534f119530"), "name" : "2" } { "_id" : ObjectId("5b450274dc396f534f119531"), "name" : "3" } { "_id" : ObjectId("5b450276dc396f534f119532"), "name" : "42" } rs0:PRIMARY> database.col.update({name: "1"}, {name: "21"}) WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 }) rs0:PRIMARY> database.col.find({}) { "_id" : ObjectId("5b45026edc396f534f11952f"), "name" : "21" } { "_id" : ObjectId("5b450272dc396f534f119530"), "name" : "2" } { "_id" : ObjectId("5b450274dc396f534f119531"), "name" : "3" } { "_id" : ObjectId("5b450276dc396f534f119532"), "name" : "42" } rs0:PRIMARY> session.commitTransaction() rs0:PRIMARY> //   rs0:PRIMARY> database.col.find({}) { "_id" : ObjectId("5b45026edc396f534f11952f"), "name" : "21" } { "_id" : ObjectId("5b450272dc396f534f119530"), "name" : "2" } { "_id" : ObjectId("5b450274dc396f534f119531"), "name" : "3" } { "_id" : ObjectId("5b450276dc396f534f119532"), "name" : "42" } rs0:PRIMARY> //   ,     rs0:PRIMARY> session.startTransaction() rs0:PRIMARY> database.col.update({name: "21"}, {name: "1"}) WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 }) rs0:PRIMARY> database.col.find({}) { "_id" : ObjectId("5b45026edc396f534f11952f"), "name" : "1" } { "_id" : ObjectId("5b450272dc396f534f119530"), "name" : "2" } { "_id" : ObjectId("5b450274dc396f534f119531"), "name" : "3" } { "_id" : ObjectId("5b450276dc396f534f119532"), "name" : "42" } rs0:PRIMARY> //   rs0:PRIMARY> session.abortTransaction() rs0:PRIMARY> database.col.find({}) { "_id" : ObjectId("5b45026edc396f534f11952f"), "name" : "21" } { "_id" : ObjectId("5b450272dc396f534f119530"), "name" : "2" } { "_id" : ObjectId("5b450274dc396f534f119531"), "name" : "3" } { "_id" : ObjectId("5b450276dc396f534f119532"), "name" : "42" } rs0:PRIMARY> // !     ! rs0:PRIMARY> 

इस प्रकार, बिना तनाव के, आप एक बहुस्तरीय क्लस्टर शुरू किए बिना अभी मोंग लेनदेन की कोशिश कर सकते हैं। मैं आपको दस्तावेज़ देखने और लेनदेन प्रतिबंधों के बारे में पढ़ने की सलाह देता हूं। उदाहरण के लिए, वह लेनदेन "लाइव" 1 मिनट से अधिक समय तक नहीं रहता है, यदि आप परिवर्तनों को सहेजने का प्रबंधन नहीं करते हैं, तो वे रद्द कर दिए जाएंगे।

पुनश्च: इस लेख का उद्देश्य आपको डॉक का उपयोग करना या मोंगा के साथ काम करना नहीं सिखाना है, बल्कि इस दिलचस्प DBMS के नए उपकरणों को आज़माने का एक त्वरित तरीका है।