MySql -> टंगस्टन प्रतिकृति का उपयोग करते हुए ओरेकल प्रतिकृति

इसलिए, शुरुआत में कुछ शब्द, एक ला प्रस्तावना। यह मैनुअल पहले उदाहरण में या लाइन-बाय-लाइन लीडरशिप के लिए सही होने का दावा नहीं करता है। लिपियों को बहुत बेहतर लिखा जा सकता है। टीमें - पढ़ने के समय, वे अलग-अलग लग सकते हैं (लेखन के समय भी, साइट पर प्रलेखन वास्तविक टीमों से भिन्न होता है)। बहुत सारी स्क्रिप्ट्स रूट के तहत की गई हैं, जो कि पूरी तरह से सही भी नहीं हैं, लेकिन फिलहाल यह काम करेगी और फिर इसे ठीक कर देगी - मैंने इसे अभी के लिए छोड़ दिया है। आपको टंगस्टन वेबसाइट (http://code.google.com/p/tungsten-replicator/) पर प्रलेखन में मूल प्रश्नों के उत्तर मिलेंगे।

उद्देश्य:

CentOS 5.5 वाले सर्वर पर MySql (5.5) से Oracle (11.2) तक प्रतिकृति की आवश्यकता थी। उस समय, यह सब कुछ नहीं है, लेकिन सिर्फ बड़ी टेबलें हैं जो बहुत जल्दी भर जाती हैं, बहुत जल्दी और आंकड़ों से जुड़ी होती हैं। हम इसे जोड़ते हैं कि MySql सर्वर पर जगह के साथ समस्याएं हैं, और निष्कर्ष के रूप में, प्रतिकृति फ़िल्टरिंग उस पर होनी चाहिए। खैर, और यदि आवश्यक हो - दोनों सर्वरों पर जगह के कारण फिर से सभी संभव अस्थायी फ़ाइलों को साफ करें।



तो चलिए शुरू करते हैं।

स्थापना:

MySql पर आपको RAW प्रारूप में बिनलॉग्स लगाने की आवश्यकता है। यह विशेष रूप से स्क्रिप्ट को फ़िल्टर करने के लिए आवश्यक था और व्यावसायिक तर्क का हिस्सा था। यदि आपको अपनी स्वयं की स्क्रिप्ट को फ़िल्टर करने, या लिखने की आवश्यकता नहीं है, तो यह संभव है कि बिनोग्राफ के प्रारूप को न बदलें।

हम स्वयं टंगस्टन प्रतिकृति डाउनलोड करते हैं (http://code.google.com/p/tungsten-replicator/), और इसे विज़ार्ड (MySql सर्वर) और दास (Oracle) पर स्थापित करते हैं। इसमें माणिक और जावा की आवश्यकता होगी। मैंने बिना किसी समस्या के वितरण से सब कुछ स्थापित किया।

हम निम्नलिखित योजना के अनुसार टंगस्टन काम करेंगे:



विज़ार्ड के लिए स्थापना स्क्रिप्ट:

./tools/tungsten-installer --master-slave -a --cluster- होस्ट = 127.0.0.1 \ _
--मास्टर-होस्ट = 127.0.0.1 \
--user = मूल \
-होम-निर्देशिका = / ऑप्ट / प्रतिकृति \
--दासोर्स-पोर्ट = 3306 \ _
--डाटासोर्स-उपयोगकर्ता = \
--डाटसोर्स-पासवर्ड = \
- सेवा-नाम = oracle \
--rmi-port = 10000 \
--thl-port = 2112 \
--mysql-enable-enumtostring = true \
--mysql-use-bytes-string = false \ के लिए
-स्काइप-सत्यापन-जांच = MySQLNoMySQLReplicationCheck

सामान्य तौर पर - मुझे लगता है कि सब कुछ स्पष्ट है, "सेवा-नाम" - सेवा को कैसे कहा जाएगा, और एक योजना पेशी में दिखाई देगी - टंगस्टन_ <सेवा-नाम>। वह अब भी हमारे लिए उपयोगी है।

वह उपयोगकर्ता जिसके तहत केवल मूल उदाहरण में घूमता है, फिर या तुरंत पुनर्व्यवस्थित करता है कि कौन सा आपके लिए अधिक सुविधाजनक है। उदाहरण जड़ का उपयोग करेंगे।

गुलाम पर:

./tools/tungsten-installer --master-slave -a --cluster- होस्ट = localhost \
--user = मूल \
--मास्टर-होस्ट = <विज़ार्ड IP> \
-होम-निर्देशिका = / ऑप्ट / प्रतिकृति \
--दासोर्स-प्रकार = oracle \
- दत्तास्रोत-अलंकरण-सेवा = \
--डाटासोर्स-उपयोगकर्ता = \
--डाटसोर्स-पासवर्ड = \
- सेवा-नाम = frommysql \
--rmi-port = 10000 \
--मास्टर-thl-port = 2112

अब तक, सब कुछ सरल है। इन मुश्किल कामों को करने के बाद - हम केवल उस फ़ोल्डर में कॉपी के साथ काम करेंगे, जहां हमने इंस्टॉल किया था (/ ऑप्ट / रिप्लाई / ...)।

हम प्रतिकृति शुरू करने की जल्दी में नहीं हैं, क्योंकि तुरंत यह किसी भी तरह से सही ढंग से शुरू नहीं होता है - यह लॉग की कमी के लिए लॉग में कसम खाएगा, क्योंकि स्कीमा नाम के आधार पर कॉन्फ़िगर नाम वांछित होंगे। मेरे मामले में static-oracle.properties को स्थिर करने के लिए replicator.properties- <स्कीमा नाम> .properties का नाम बदलें।

विज़ार्ड पर निर्दिष्ट करें कि कौन से फ़िल्टर का उपयोग किया जाएगा: कॉन्फ़िगरेशन (/ ऑप्ट / रिप्लाई / टंगस्टन / टंगस्टन-रेप्लिकेटर / कन्फ़ / / ...) में:

replicator.stage.binlog-to-q.filters = dropcomments, filtertables, dbupper

और फिल्टर के लिए रास्ता है, और तदनुसार तालिकाओं कि दोहराया जाएगा:

replicator.filter.filtertables = com.continuent.tungsten.replicator.filter.JavaScriptFilter
replicator.filter.filtertables.script = / opt / reply / tungsten / tungsten-replicator / filtertables.js
replicator.filter.filtertables.include = idp.abyrvalg, idp.transactions

इस स्थिति में, आईडीपी स्कीमा और एबिरवाल्ग और लेनदेन तालिकाओं।

हम यह सुनिश्चित करते हैं कि मास्टर उस बंदरगाह को सुनता है जिस पर दास उसे thl लॉग इकट्ठा करने के लिए एक्सेस करेगा

replicator.master.listen.uri = thl: //0.0.0.0: 2112 /

Replicator.source_id में = कोई भी विशिष्ट नाम निर्दिष्ट करें। सबसे आसान तरीका एक आईपी सर्वर है। मेरे मामले में - 192.168.40.3

कहानी के अंत में, मुकाबला कॉन्फ़िगरेशन संलग्न किया जाएगा और निश्चित रूप से, एक फिल्टर स्क्रिप्ट।

विज़ार्ड पर प्रतिकृति प्रारंभ करें ।/replicator प्रारंभ करें
आइए इसके संक्रमण की जांच ऑनलाइन करें - ./repctl स्थिति, यदि ऑफ़लाइन है - .trepctl ऑनलाइन

यदि ऑनलाइन स्थिति का अर्थ है कि सब कुछ ठीक है, तो उसने MySql binlogs (डिफ़ॉल्ट रूप से, जब वे गीगाबाइट्स से अधिक हो जाते हैं) को संग्रहीत करना शुरू कर दिया - और फ़ाइलों को thl - वास्तव में, कि वह एक दास भेजेगा, इस पर थोड़ी देर बाद चर्चा की जाएगी। कोई समस्या नहीं होनी चाहिए।

क्रमशः दास पर, विन्यास फाइल का नाम बदलकर स्थिर- <स्कीमा नाम> .properties, मेरे मामले में static-frommysql.properties है।

हम यह सुनिश्चित करते हैं कि replicator.master.connect.uri = thl: // <IP मास्टर्स>: 2112 के मूल्य में IP मास्टर्स बिल्कुल सेट हैं, दिखावे और पासवर्ड सही हैं।

replicator.source_id = - फिर से, कोई भी विशिष्ट मूल्य,
टिप्पणी बाहर replicator.store.thl.storageListenerUri

हम एक सारणी के दास में निर्दिष्ट तालिका के अनुरूप तालिका बनाते हैं;

हम एक गुलाम शुरू करते हैं --/replicator start
यदि वह ऑनलाइन स्थिति से स्थिति से स्विच करता है - सब कुछ ठीक है। यदि नहीं, तो वह लॉग और स्टेटस में शपथ लेगा।

आप मेस्टर और स्लेव पर बनाई गई योजनाओं में जा सकते हैं, और ध्यान दे सकते हैं - trep_commit_seqno में seqno और epoch_number परिवर्तन के मानों की तालिका।

यदि सब कुछ ठीक है - तो आप आवरण के संपादन से लॉगिंग के स्तर को कम कर सकते हैं

रोगी की थोड़ी देखभाल।

Thl मास्टर पर लॉग में निर्दिष्ट के रूप में लॉग संग्रहीत हैं, डिफ़ॉल्ट दिन है। (replicator.store.thl.log_file_retention =), जिस चीज़ की हमें ज़रूरत है, उसी चीज़ को गुलाम में बदल दें। लेकिन अगर हमें अंतरिक्ष को खाली करने की तत्काल आवश्यकता है, तो हमें इसे मैन्युअल रूप से करना होगा। मुख्य बात अंतिम घटना को मिटाना नहीं है।

मास्टर पर, डिफ़ॉल्ट रूप से बिन लॉग 1 गीगाबाइट (/ ऑप्ट / रिप्लाई / रिले / ...) से अधिक के आकार में संग्रहीत किया जाता है, लेकिन गुलाम और मास्टर पर मैन्युअल रूप से thl को साफ करने के लिए, आपको पहले से रिकॉर्ड किए गए घटनाओं के ऊपरी और निचले मूल्यों को देखने की जरूरत है।

दरअसल, गुरु और गुलाम पर यह स्क्रिप्ट मेरे लिए ऐसा कर रही है।

#! / बिन / श
सीडी / ऑप्ट / रिप्लाई / टंगस्टन / टंगस्टन-रेप्लिकेटर / बिन
MINVALUE = `। / Thl -service frommysql जानकारी | grep "min seq # =" | awk '{प्रिंट $ 4;}' '
MAXVALUE = `/ ट्रेपक्टल स्थिति | grep "applyLastSeqno:" | awk '{प्रिंट $ 3;}' '
MAXVALUENEW = `प्रतिध्वनि" $ MAXVALUE-1000 "| bc`
./trepctl -service frommysql ऑफ़लाइन
सो जाओ १०
./thl पर्ज -लो $ MINVALUE -High $ MAXVAskyrimLUENEW -y
.trepctl -service frommysql ऑनलाइन

थोडा समस्या निवारण।

अगर हमने गलती से सुपरफ़्लस को मिटा दिया है, या सर्वर के बीच नेटवर्क लंबे समय तक पड़ा है, या कई कारण थे, लेकिन कनेक्ट करते समय, दास लिखते हैं कि अलस और आह - लेकिन वह स्थिति एन चाहता है, लेकिन मास्टर ऐसा नहीं करता है, जैसे कुछ:

जानकारी | jvm 1 | 2011/11/24 11:32:54 | 2011-11-24 11: 32: 54,432 [oracle - कनेक्टर-हैंडलर-192.168.39.50] ERROR thl.ConnectorHandler कनेक्टर हैंडलर को THL अपवाद द्वारा समाप्त किया गया: लॉग की विफलता: अपेक्षित sebno = XXXXXXX seqno = YYYYYYYYYYYYYYYYYYYYYYYYYYYYYYYYYYYY

(हम स्थिति में या लॉग में अधिक सटीक रूप से देखते हैं) - आपको इसे थोड़ा साफ करना होगा।

दास पर प्रतिकृति बंद करो। हम प्रतिलिपि किए गए thl लॉग मिटाते हैं। Trep_commit_seqno टेबल पर ध्यान दें। Seqno और epoch_number के मूल्यों को मिटा दें, या मास्टर द्वारा अपेक्षित मूल्यों को निर्धारित करें, जो वह चाहता है पर निर्भर करता है। हम शुरू करते हैं। अगला, निश्चित रूप से, आपको MySql से Oracle तक (csv) के माध्यम से पुराने ढंग से खोए हुए टुकड़े को आसवन करना होगा।

एक विशिष्ट स्थिति से पढ़ना भी संभव है, आधिकारिक वेबसाइट पर प्रलेखन देखें, पैराग्राफ 4.3.x

विज़ार्ड कॉन्फिग, स्लेव कॉन्फिग और js फ़िल्टर स्क्रिप्ट:

_http: //zalil.ru/32217860

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