उपलब्धता समूह के द्वितीयक प्रतिकृतियों पर आँकड़े अद्यतन करना

हम सभी माध्यमिक प्रतिकृतियों पर उपलब्धता समूह की अद्भुत विशेषताओं का प्यार और उपयोग करते हैं, जैसे कि अखंडता की जाँच, बैकअप आदि।

वास्तव में, एक प्रतिकृति पर एक डेटाबेस में इस जानकारी को बचाने में असमर्थता अभी भी सिरदर्द है (और सीडीसी जैसी चीजों के बारे में और भी अधिक असुविधा के बारे में सोचें)।

लेकिन शिकायत करना बंद करो, यहां मुख्य विचार है: प्रिय माइक्रोसॉफ्ट, हमें अपने cues का उपयोग आंकड़ों को अपडेट करने के लिए करना चाहिए ... ठीक है, उन पर बहुत कुछ करें।

हमेशा * एक रास्ता है, या ऐसा कुछ है

* लगभग हमेशा

आइए एंटरप्राइज एडिशन MS SQL सर्वर पर संभावित समाधान के ज्ञात बुनियादी विवरणों को सूचीबद्ध करें:

• हम प्रतिकृतियों को पढ़ने योग्य बना सकते हैं और उनसे डेटा पढ़ सकते हैं (ऐसा नहीं है कि आपको हमेशा ऐसा करना था, लेकिन यदि आप वास्तव में जानते हैं कि आप क्या कर रहे हैं ...);
• हम अपनी वस्तुओं को Tempdb पर कॉपी कर सकते हैं (हाँ, आपकी बहु-टेराबाइट टेबल शायद इस तरह के ऑपरेशन के लिए बहुत उपयुक्त नहीं हैं), या किसी अन्य डेटाबेस के लिए जो कि योग्य है;
• हम परिणामों को एक साझा फ़ोल्डर में लिख सकते हैं जो दोनों प्रतिकृतियों के लिए सुलभ है (इसे एक फाइल शेयर में एक पाठ फ़ाइल हो);
• हम SQL सर्वर से एक बूँद के रूप में आँकड़ों का निर्यात कर सकते हैं;
• हम आँकड़ों में डाउनलोड बूँद आयात कर सकते हैं।

चलो करते हैं

मेरे पास SQL ​​Server 2017 के साथ आभासी मशीनों की एक जोड़ी पर एक परीक्षण एजी है (आप किसी भी संस्करण का उपयोग कर सकते हैं) और मैं एक सरल तालिका बनाऊंगा जिसमें मैं आंकड़े अपडेट करना चाहता हूं।

यहाँ एक तालिका बनाने और उसमें एक लाख पंक्तियाँ डालने की स्क्रिप्ट है:

DROP TABLE IF EXISTS dbo.SampleDataTable; CREATE TABLE dbo.SampleDataTable ( C1 BIGINT NOT NULL, C2 BIGINT NOT NULL, CONSTRAINT PK_SampleDataTable PRIMARY KEY (C1) ); INSERT INTO dbo.SampleDataTable WITH (TABLOCK) SELECT t.RN, t.RN FROM ( SELECT TOP (1000000) ROW_NUMBER() OVER (ORDER BY (SELECT NULL)) RN FROM sys.objects t1 CROSS JOIN sys.objects t2 CROSS JOIN sys.objects t3 CROSS JOIN sys.objects t4 CROSS JOIN sys.objects t5 ) t OPTION (MAXDOP 1); 

अब कॉलम c2 पर ST_SampleDataTable_C2 आँकड़े बनाते हैं

 CREATE STATISTICS ST_SampleDataTable_C2 ON dbo.SampleDataTable(C2); 

और फिर मैं 1000 पंक्तियों को सम्मिलित करूंगा, जो बहुत महत्वपूर्ण होगा और जिसके कारण मुझे वास्तव में आँकड़ों को अपडेट करने की आवश्यकता है।

 set nocount on; INSERT INTO dbo.SampleDataTable WITH (TABLOCK) SELECT 10000000 + t.RN, 999999999 FROM ( SELECT TOP (1000) ROW_NUMBER() OVER (ORDER BY (SELECT NULL)) RN FROM sys.objects t1 CROSS JOIN sys.objects t2 CROSS JOIN sys.objects t3 CROSS JOIN sys.objects t4 CROSS JOIN sys.objects t5 ) t OPTION (MAXDOP 1); 

अब मेरे पास 1000 प्रविष्टियाँ हैं, जिसमें स्तंभ C2 में, मान 999999999 है। और इसका निश्चित रूप से आरोही कुंजी समस्या है और मुझे वास्तव में आँकड़ों को अद्यतन करने की आवश्यकता है ... प्रतिकृति पर ताकि मैं गणना के साथ मुख्य सर्वर को तनाव न दूं उसे ग्राहकों की सेवा करने से रोका।

अच्छे पुराने DBCC SHOW_STATISTICS कमांड का उपयोग करते हुए, आइए हमारे आँकड़ों की जाँच करें।

 DBCC SHOW_STATISTICS('dbo.SampleDataTable', 'ST_SampleDataTable_C2') 

हमारे राज्य में सब कुछ सही है और हमारे आंकड़े सही क्रम में हैं, हालांकि यह केवल 1 मिलियन लाइनों को ध्यान में रखता है और कोई भी हानिकारक हजार लाइनें नहीं हैं, जो अंततः, इन आंकड़ों का हिस्सा बनना चाहिए।

इसके अलावा, हम DBCC SHOW_STATISTICS के STATS_STREAM पैरामीटर का उपयोग करके सांख्यिकी स्ट्रीम देख सकते हैं:

 DBCC SHOW_STATISTICS('dbo.SampleDataTable', 'ST_SampleDataTable_C2') WITH STATS_STREAM; 

यह सिर्फ एक चरित्र है कि ब्लॉग सालों से लिखते आ रहे हैं, लेकिन मुझे अभी भी यकीन नहीं है कि यह पूरी तरह से प्रलेखित फीचर है (हालांकि इसने लोगों को इसे इस्तेमाल करने से कभी नहीं रोका)।

क्यू पर

आइए हमारी तालिका को एक प्रतिकृति पर tempdb पर कॉपी करें (हालांकि मेरा एजी सिंक्रोनस मोड में है, वही काम एसिंक्रोनस में किया जा सकता है, बस डेटा थोड़ी देरी के साथ आ सकता है)।

 use TempDB; DROP TABLE IF EXISTS dbo.SampleDataTable; CREATE TABLE dbo.SampleDataTable ( C1 BIGINT NOT NULL, C2 BIGINT NOT NULL, CONSTRAINT PK_SampleDataTable PRIMARY KEY (C1) ); INSERT INTO dbo.SampleDataTable SELECT C1, C2 FROM AvGroupDb.dbo.SampleDataTable; 

अब हम प्रतिकृति पर tempdb में पूर्ण स्कैन के साथ आँकड़ों को अपडेट करने के लिए तैयार हैं।

 use TempDB; UPDATE STATISTICS ST_SampleDataTable_C2 ON dbo.SampleDataTable(C2) WITH FULLSCAN; 

( अनुवादक का नोट - नीको आँकड़े बनाना भूल गया, और UPDATE STATISTICS ऑपरेशन के गलत सिंटैक्स का उपयोग करता है, UPDATE के बजाय इसे CREATE किया जाना चाहिए, अर्थात आँकड़े अद्यतन नहीं किए गए हैं, लेकिन बनाए गए हैं )

DBCC SHOW_STATISTICS पर वापस जाएं और इसे देखें:

 DBCC SHOW_STATISTICS('dbo.SampleDataTable', 'ST_SampleDataTable_C2') 

यह मुख्य सर्वर पर जो था उससे पूरी तरह से अलग दिखता है - केवल 3 लाइनें बनाम 178, लेकिन यह पूरी तरह से डेटा का वर्णन करता है - हमारे पास एक लाख अद्वितीय रेखाएं हैं और 1000 लाइनें समान C2 कॉलम मान के साथ हैं - हिस्टोग्राम जितना संभव हो उतना अच्छा है ।

आइए आँकड़ों के प्रवाह को देखें:

 DBCC SHOW_STATISTICS('dbo.SampleDataTable', 'ST_SampleDataTable_C2') WITH STATS_STREAM; 

आपको यह देखने के लिए एक जीनियस होने की आवश्यकता नहीं है कि धारा पूरी तरह से अलग दिखती है - हम अद्यतन स्ट्रीम में 5689A0C6 वर्णों को देखते हैं, जबकि मूल में, इन सभी शून्य के बीच हमने EDF10EB4 देखा।

चलो SQL सर्वर के बाहर कहीं पाठ फ़ाइल में इस डेटा को निर्यात करने पर ध्यान केंद्रित करते हैं और इसे अद्भुत BCP कमांड की सहायता से करते हैं, जिसके लिए CMDSHELL को सक्षम करने की आवश्यकता होती है (ध्यान दें: आप शायद अपने उत्पादन सर्वर पर ऐसा नहीं चाहते):

 EXEC xp_cmdshell 'BCP "DBCC SHOW_STATISTICS(''AvGroupDb.dbo.SampleDataTable'', ''ST_SampleDataTable_C2'') WITH STATS_STREAM" queryout \\SharedServer\Tempdb\stats.txt -c -T'; 

और यहां बताया गया है कि हमारे बॉल में कितने बड़े आँकड़े हैं।



बस एक दो किलोबाइट! ट्रांसमिट करना आसान, मैनेज करना आसान।

मुख्य सर्वर पर वापस

मुख्य सर्वर पर, हमें एक अस्थायी तालिका बनाने की आवश्यकता होगी जो आंकड़े स्ट्रीम को संग्रहीत करेगी, इससे पहले कि हम अपने मुख्य नमूना डेटा तालिका में आंकड़ों को अपडेट कर सकें (व्यवहार में, हम कई डेटाबेस, तालिकाओं, आंकड़ों के लिए इस तालिका का विस्तार कर सकते हैं)।

 CREATE TABLE dbo.TempStats( Stats_Stream VARBINARY(MAX), Rows BIGINT, DataPages BIGINT ); 

आइए अपनी पाठ फ़ाइल से डेटा को हमारी नई अस्थायी तालिका में आयात करें और देखें कि हमने क्या आयात किया है:

 BULK INSERT dbo.TempStats FROM '\\SharedServer\Tempdb\stats.txt' SELECT * FROM dbo.TempStats; 

हम उसी डेटा को देख सकते हैं जिसकी हमने प्रतिकृति पर गणना की है, लेकिन यह डेटा पहले से ही हमारे मुख्य सर्वर पर है और हमारे लिए जो कुछ भी करना बाकी है वह तालिका में हमारे आंकड़ों को अपडेट करता है। यह ऑपरेशन STATS_STREAM = ... पैरामीटर के साथ UPDATE STATISTICS ऑपरेशन का उपयोग करके किया जा सकता है

 DECLARE @script NVARCHAR(MAX) SELECT @script = 'UPDATE STATISTICS dbo.SampleDataTable(ST_SampleDataTable_C2) WITH STATS_STREAM = ' + CONVERT(nvarchar(max), [Stats_Stream],1) FROM dbo.TempStats PRINT @script; EXECUTE sp_executesql @script; 

यह स्क्रिप्ट ऊपर आयातित मान को पढ़ता है (हाँ, मुझे पता है - मैंने यह उदाहरण एक तालिका के लिए किया था और कई आँकड़ों, तालिकाओं, डेटाबेसों आदि से परेशान नहीं था), एक अद्यतन स्टेटमेंट कथन उत्पन्न करता है, इसे स्क्रीन पर प्रदर्शित करता है और अंत में, प्रदर्शित करता है। उसे पूरा करता है।
यहाँ मुझे आउटपुट में क्या मिलता है:

 UPDATE STATISTICS dbo.SampleDataTable(ST_SampleDataTable_C2) WITH STATS_STREAM = 

मुख्य सर्वर पर DBCC SHOW_STATISTICS चलाने से मुझे वही परिणाम मिलता है जिसकी मैं उम्मीद कर रहा था - जैसा कि हमने प्रतिकृति पर देखा था। सर्कल बंद है।

 DBCC SHOW_STATISTICS('dbo.SampleDataTable', 'ST_SampleDataTable_C2'); 

इस कहानी का वास्तव में भयानक हिस्सा यह है कि आंकड़ों के साथ ऑब्जेक्ट का आकार बहुत छोटा है और हम इसे मुख्य सर्वर पर बहुत आसानी से / तुरंत स्थानांतरित कर सकते हैं।

इतना बुनियादी परिदृश्य नहीं।

यदि आपके पास समान प्रतिकृतियों के बीच कई एजी हैं, जहां एक प्रतिकृति एक एजी में मुख्य है और दूसरी में मुख्य है, तो आप प्रतिकृतियों के बीच डेटा स्ट्रीम में BLOB डेटा सम्मिलित कर सकते हैं और प्रेषित डेटा के साथ एक छोटा डेटाबेस जोड़ सकते हैं।



चित्र को देखो। यदि हमारे पास दो AGs (AG1 & AG2) हैं, जो विभिन्न सर्वरों पर स्थित हैं और हमारे पास AG1 में Server1 पर एक विशिष्ट तालिका है, जिसके लिए हम आंकड़े अपडेट करना चाहते हैं, तो Server2 पर हम इस तालिका को कॉपी कर सकते हैं (इसे dbo कहते हैं। ) tempdb में, अद्यतन करें, और AG2 का उपयोग करके ऑब्जेक्ट को सर्वर 1 में वापस स्ट्रीम स्ट्रीम के साथ भेजें, जहां आप केवल इस स्ट्रीम से आंकड़े आयात करते हैं जो हमें आवश्यक आंकड़े हैं।

हां, मुझे पता है, यह भ्रामक लगता है, लेकिन इसे एक फीडबैक चैनल के रूप में सोचें, जिसके माध्यम से परिणाम वितरित किए जाते हैं, बजाय फाइल बॉल के।

संदेह के लिए जगह

उदाहरण के लिए, आपको कुछ आपत्तियाँ हो सकती हैं:

• अगर मैं इसे मुख्य सर्वर पर सुरक्षित रूप से कर सकता हूं तो मुझे प्रतिकृति पर ऐसा क्यों करना चाहिए? (ठीक है, विचार मुख्य सर्वर को बंद करना है)
• लेकिन हम, संभावित रूप से, प्रतिकृति को लोड नहीं करते हैं (हां, लेकिन अगर यह निष्क्रिय है, यही कारण है कि हम इसकी शक्ति का उपयोग करना चाहते हैं)
• और हम किसी भी तरह मुख्य सर्वर पर कार्य नहीं कर सकते हैं? (नहीं, हम सिर्फ प्रतिकृति से डेटा पढ़ते हैं और कुछ किलो किलोबाइट वापस भेजते हैं, जो हमारी शताब्दी में गीगाबाइट्स और टेराबाइट्स "shtoa?" की तरह लगता है) ( नोट अनुवादक - सामान्य तौर पर, केवल प्रतिकृति प्रतिकृति के मामले में, हम कर सकते हैं )
• क्या होगा अगर प्रक्रिया के बीच में मुख्य सर्वर अपने आप ही आंकड़ों को अपडेट करना शुरू कर देता है? (इस मामले में, यह या तो दूसरी प्रक्रिया को बाधित कर सकता है, या अपडेट किए गए डेटा के साथ पुनरारंभ कर सकता है)।

एजी प्रतिक्रिया चैनल

यह प्रतिकृति से मुख्य सर्वर के साथ एक चैनल है - हमने सिंक्रोनस एजी में लेन-देन की प्रतिज्ञा के बाद, मुख्य सर्वर प्रतिकृति से पुष्टि की प्रतीक्षा करेगा - और मुझे लगता है कि इस सुधार को लागू करने के लिए इस चैनल का उपयोग किया जा सकता है। उस तस्वीर को देखें, जिसे साइमन सु द्वारा पोस्ट में लिया गया था।



जो मौजूदा प्रतिक्रिया चैनल के पूरे तंत्र का प्रतिनिधित्व करता है। स्टेप 12 और बाद के चरण का उपयोग करते हुए, प्राथमिक सर्वर की पुष्टि करता है कि जानकारी सहेज ली गई है। एक प्रतिकृति पर पुनरावृत्ति करने के बाद एक डेटा प्रवाह ऑब्जेक्ट भेजने के लिए उसी चैनल का उपयोग किया जा सकता है। बेशक, हमें इस उद्देश्य के लिए tempdb का उपयोग नहीं करना होगा, लेकिन डेटाबेस के अंदर एक इन-मेमोरी ऑब्जेक्ट बनाएं, जिसे स्थायी रूप से संग्रहित नहीं किया जाना चाहिए (अपने इन-मेमोरी ओएलटीपी स्कीमा-ओनली टेबल को देखें, या ओरेकल में NOLOGGING तालिकाओं के बारे में सोचें), और ऑपरेशन के अंत में हटा दिया जाना चाहिए - जो वास्तव में अच्छा होगा।

सामान्य विचार

यह इस बात पर निर्भर नहीं होना चाहिए कि समकालिक प्रतिकृति या नहीं - अधिकांश समय आँकड़े हर कुछ सेकंड में अपडेट नहीं किए जाते हैं और यह हमें विचार के दूसरे भाग तक ले जाता है - मुख्य सर्वर पर आँकड़ों को अद्यतन करने के लिए एक पैरामीटर के साथ, जैसे कि

 UPDATE STATISTICS dbo.MyAwesomeTable(HugeImportantStatOnC17) WITH FULLSCAN, SECONDARY 

जहां सुरक्षा पैरामीटर इंगित करता है कि ऑपरेशन कहां किया जाना है।
और बैकअप के साथ की तरह, हम सेटिंग्स में अद्यतन सांख्यिकी (या भविष्य में किसी भी अन्य ऑपरेशन) प्रदर्शन करने के लिए पसंदीदा प्रतिकृति निर्दिष्ट करने में सक्षम होना चाहिए।

मुझे यकीन है कि यह सुविधा कई एंटरप्राइज़ संस्करण उपयोगकर्ताओं को SQL सर्वर के नए संस्करण में स्थानांतरित करने के लिए प्रोत्साहित करेगी, जो प्रतिकृतियों के बीच भारी संचालन को वितरित करने की अनुमति देगा।

वर्तमान स्थिति के रूप में - मैं वास्तव में देखता हूं कि आप पॉवर्सशेल का उपयोग करके इस समाधान को कैसे स्वचालित कर सकते हैं।

Microsoft, अब आपकी बारी है! ;)

यहां प्रस्तावित सुविधा के लिए वोट करें ।

अनुवादक का ध्यान दें: अनुवाद और स्टाइल पर किसी भी सुझाव और टिप्पणी का स्वागत है, हमेशा की तरह।

मुझे आमतौर पर अनुवाद में प्राथमिक प्रतिकृति "प्राथमिक सर्वर" कहा जाता है, और माध्यमिक प्रतिकृति - बस एक प्रतिकृति। शायद यह पूरी तरह से सही नहीं है, लेकिन मेरा कान एमएसडीएन पर "प्राथमिक" और "माध्यमिक" प्रतिकृतियों की तुलना में कम दर्द होता है।