Bazani yuklama ostida ko‘chirish va yozuvlarni yo‘qotmaslik

O‘tishning besh bosqichi

Ikki tomonlama yozuv: u qayerda buziladi

Sodda ikki tomonlama yozuv ketma-ket ikkita chaqiruvga o‘xshaydi va xato o‘z ichiga oladi: agar ikkinchi yozuv yiqilsa, sizda allaqachon farq bor, foydalanuvchiga esa muvaffaqiyatli saqlangan ma’lumot ustida xato qaytdi. «Qaysi ombor asosiy» degan savolga javob butun o‘tish davomida bir xil bo‘lishi kerak.

async function save(record: Record) {
  // O'tish davrida haqiqat manbai — eski ombor.
  await legacy.save(record);

  try {
    await next.save(record);
  } catch (err) {
    // So'rovni yiqitmaymiz: foydalanuvchi o'zi bilmagan migratsiyadan
    // aziyat chekmasligi kerak. Farqni qayd etamiz va fonda tuzatamiz.
    metrics.increment('migration.dual_write.failed');
    await outbox.enqueue({ type: 'migration.resync', id: record.id });
  }
}

Solishtirish: nazorat yig‘indilari, tanlab tekshirish emas

«O‘nta yozuvni ochdik, hammasi mos keldi» hech nimani isbotlamaydi. Ishlaydigan usul — diapazonlar bo‘yicha nazorat yig‘indilari: ma’lumotni oraliqlarga bo‘lamiz, har biri bo‘yicha ikkala omborda agregatni hisoblaymiz va taqqoslaymiz. Farq darhol lokallashadi, satrma-satr esa faqat shubhali oraliqni taqqoslash kerak bo‘ladi.

select
  date_trunc('day', created_at) as bucket,
  count(*)                      as rows,
  sum(amount)                   as total,
  md5(string_agg(id::text || ':' || amount::text, ','
      order by id))             as checksum
from operation
where created_at < :cutoff
group by 1
order by 1;

Soyali o‘qish ikkinchi, mustaqil signal qo‘shadi: tizim so‘rovni eski ombordan bajaradi, parallel ravishda o‘sha so‘rovni yangisiga yuboradi va natijalarni taqqoslaydi. Farqlar logga yoziladi. Bu ma’lumot solishtirishi ko‘rmaydigan narsani tutadi — tanlash mantiqidagi farqlarni: boshqa saralash tartibi, NULL da boshqacha xatti-harakat, boshqa yaxlitlash.

Aslida nima buziladi

Yozuvlar deyarli hech qachon butunlay yo‘qolmaydi — ularning ma’nosi yo‘qoladi. Quyidagi ro‘yxat solishtirishda haqiqatan chiqadigan narsalardan yig‘ilgan.

• Bo‘sh satrga qarshi `NULL`. Eski bazada «qiymat yo‘q» '' sifatida yozilgan, yangisida — NULL. Filtrlar yozuvlarni topmay qo‘yadi, hisobotlar esa jimgina raqamlarini o‘zgartiradi.
• Vaqt mintaqalari. Vaqt zonasiz saqlangan va mahalliyni nazarda tutgan; yangi bazada — timestamptz. Amallar bir necha soatga siljiydi va bu faqat sutka chegaralarida ko‘rinadi — ya’ni hisobotlarda.
• Pulni yaxlitlash. Eski tizimdagi float va yangisidagi numeric tiyinlarda farq beradi, u to‘planadi va yakunlarda to‘g‘ri chiqmaydi.
• Avtoinkrementlar. Yangi ombor raqamlashni birdan boshlaydi va ko‘chirilgan identifikatorlar ustiga chiqadi. Hisoblagich yozuvni yoqishdan oldin aniq qo‘yiladi.
• Unikallik. Eski bazada yangi sxema yo‘l qo‘ymaydigan dublikatlar to‘plangan. Ularni ko‘chirishdan oldin hal qilish kerak — bu dasturchining emas, biznesning qarori.

Ortga qaytish rejasi qanday ko‘rinadi

Ortga qaytish rejasi — bu «zaxiradan tiklaymiz» emas. Ikki tomonlama yozuv ketayotganda ortga qaytish o‘qish bayrog‘ini qaytarish demakdir: eski ombor shu vaqt davomida to‘liq va dolzarb qolgan. Aynan shuning uchun ikki tomonlama yozuv bosqichi o‘tkazishdan keyin darhol yig‘ishtirilmaydi — u arzon turadi va qaytish imkoniyatini sotib oladi.