Informazioni su questo annuncio
Cosa fa
Questo collega i sistemi attualmente in uso, come un database a un warehouse, un CRM a uno strumento di reporting, un'API a un foglio di calcolo o diverse di queste combinazioni. Il trasferimento di righe durante il normale funzionamento è semplice; la vera prova si presenta al quarantesimo giorno, quando un token di autenticazione scade alle 2:00 del mattino, una tabella di origine acquisisce un nuovo campo che ammette valori nulli o un trasferimento batch si interrompe a metà.
Come è strutturato
Estrazione, caricamento e trasformazione sono gestiti come fasi separate, poiché ciascuna può fallire per motivi differenti e richiede un proprio meccanismo di nuovo tentativo. L'estrazione segue un cursore o un watermark per garantire che un riavvio riprenda dal punto in cui si era interrotto anziché duplicare i record. Il caricamento avviene all'interno di una transazione per ogni batch, il che significa che un'interruzione lascia la destinazione in uno stato coerente anziché parzialmente aggiornato. Le regole di trasformazione risiedono in codice SQL o Python sottoposto a controllo di versione, anziché in un builder grafico che diventa difficile da leggere nel tempo.
Ogni esecuzione genera un manifest con il dettaglio delle righe lette, delle righe scritte, di quelle scartate e della causa di ciascuno scarto. Una chiave naturale associata a un hash garantisce l'idempotenza del processo, impedendo che la ripetizione di un'operazione precedente arrechi danni. Le modifiche agli schemi di origine vengono rilevate prima che causino l'interruzione di un caricamento, generando un avviso anziché un errore silenzioso.
Cosa riceve
- Codice della pipeline inviato al Vostro repository, testato su un campione dei Vostri dati reali.
- Un meccanismo di pianificazione adatto al Vostro stack: cron, un timer systemd, Airflow o Prefect.
- Monitoraggio e avvisi che coprono il conteggio delle righe, gli errori e le deviazioni di latenza.
- Un runbook che spiega la riesecuzione, il backfill e le modalità di integrazione di una nuova origine dati.
Cosa ci occorre da parte Vostra
Accesso in sola lettura ai sistemi di origine e destinazione, un campione funzionante dei dati e la pianificazione di cui la Vostra azienda ha effettivamente bisogno, anziché una eccessivamente ambiziosa.
Tempistiche e aggiornamenti
Una versione funzionale iniziale è normalmente pronta entro cinque giorni e include un'esecuzione di staging per la Vostra revisione prima del rilascio in produzione. Gli aggiornamenti vengono forniti sotto forma di brevi note scritte a ogni traguardo anziché tramite riunioni, e le scelte che incidono sui Vostri dati (come conservazione, intervalli di backfill e gestione delle righe scartate) vengono registrate per riferimenti futuri. Qualora l'affidabilità non possa essere raggiunta nei tempi consentiti, verrete informati con tempestività per consentire la modifica del piano, evitando di riscontrare problemi solo al momento del lancio.
Questa versione viene fornita come pacchetto unico a prezzo fisso, completato in un unico passaggio con una revisione inclusa ed elaborato entro un termine di 14 giorni. Dovrete indicare il dominio a cui si applica l'ordine e il Vostro brief.