database-migrations-migration-observability

name	database-migrations-migration-observability
description	Migration monitoring, CDC, and observability infrastructure
type	skill
created	2026-02-27T00:00:00.000Z
domain	cloud-infrastructure
category	monitoring
risk	unknown
source	community
tags	["skill","cloud-infrastructure","monitoring","database","migrations","migration"]

Migration Observability and Real-time Monitoring

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 } = require('winston');
const prometheus = require('prom-client');

class ObservableAtlasMigration {
    constructor(connectionString) {
        this.client = new MongoClient(connectionString);
        this.logger = createLogger({
            transports: [
                new transports.File({ filename: 'migrations.log' }),
                new transports.Console()
            ]
        });
        . = .();
    }

    () {
         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.();
        }
    }
}