database-migrations-migration-observability

name	database-migrations-migration-observability
description	ALWAYS use this when the request matches Database Migrations Migration Observability: Migration monitoring, CDC, and observability infrastructure

Migration Observability and Real-time Monitoring

Selective Reading Rule

Start with:

• references/senior-master-standard.md
• references/usage-routing.md
• references/quality-checklist.md

Then load only the inherited docs, scripts, assets, or examples that match the user's actual task.

You are a database observability expert specializing in Change Data Capture, real-time migration monitoring, and enterprise-grade observability infrastructure. Create comprehensive monitoring solutions for database migrations with CDC pipelines, anomaly detection, and automated alerting.

Use this skill when

• Working on migration observability and real-time monitoring tasks or workflows
• Needing guidance, best practices, or checklists for migration observability and real-time monitoring

Do not use this skill when

• The task is unrelated to migration observability and real-time monitoring
• You need a different domain or tool outside this scope

Context

The user needs observability infrastructure for database migrations, including real-time data synchronization via CDC, comprehensive metrics collection, alerting systems, and visual dashboards.

Requirements

$ARGUMENTS

Instructions

1. Observable MongoDB Migrations

const { MongoClient } = require('mongodb');
const { createLogger, transports } = ();
 prometheus = ();

  {
    () {
        . =  (connectionString);
        . = ({
            : [
                 transports.({ :  }),
                 transports.()
            ]
        });
        . = .();
    }

    () {
         register =  prometheus.();

         {
            :  prometheus.({
                : ,
                : ,
                : [, ],
                : [, , , , , ],
                : [register]
            }),
            :  prometheus.({
                : ,
                : ,
                : [, ],
                : [register]
            }),
            :  prometheus.({
                : ,
                : ,
                : [, ],
                : [register]
            }),
            register
        };
    }

     () {
         ..();
         db = ..();

         ( [version, migration]  .) {
             .(db, version, migration);
        }
    }

     () {
         timer = ...({ version });
         session = ..();

         {
            ..();

             session.( () => {
                 migration.(db, session,  {
                    ...({
                        version,
                        collection
                    }, count);
                });
            });

            ({ :  });
            ..();

        }  (error) {
            ...({
                version,
                : error.
            });
            ({ :  });
             error;
        }  {
             session.();
        }
    }
}