Le migliori pratiche per lavorare con DynamoDB Zero ETL Integration and Service OpenSearch

Indicizza solo i dati su cui devi eseguire ricerche. Usa sempre un modello di mappatura (template_type: index_templateandtemplate_content) e include_keys implementalo.

Monitora i log per verificare la presenza di errori correlati ai conflitti di tipo. OpenSearch Il servizio si aspetta che tutti i valori di una determinata chiave abbiano lo stesso tipo. Genera eccezioni in caso di mancata corrispondenza. Se si verifica uno di questi errori, è possibile aggiungere un processore per verificare che una determinata chiave abbia sempre lo stesso valore.

In genere, utilizzate il valore primary_key dei metadati per il document_id valore. In OpenSearch Service, l'ID del documento è l'equivalente della chiave primaria in DynamoDB. L'utilizzo della chiave primaria faciliterà la ricerca del documento e garantirà che gli aggiornamenti vengano replicati in modo coerente senza conflitti.

È possibile utilizzare la funzione di supporto per getMetadata ottenere la chiave primaria (ad esempio,document_id: "${getMetadata('primary_key')}"). Se utilizzi una chiave primaria composita, la funzione di supporto le concatenerà insieme per te.

In generale, utilizzate il valore dei opensearch_action metadati per l'impostazione. action Ciò garantirà che gli aggiornamenti vengano replicati in modo tale che i dati in OpenSearch Service corrispondano allo stato più recente di DynamoDB.

È possibile utilizzare la funzione di supporto per getMetadata ottenere la chiave primaria (ad esempio,). action: "${getMetadata('opensearch_action')}" Puoi anche visualizzare il tipo di evento stream dynamodb_event_name per casi d'uso come il filtraggio. Tuttavia, in genere non dovresti usarlo per l'actionimpostazione.

Utilizzate sempre una coda di lettere non scritte (DLQ) sui vostri OpenSearch sink per gestire gli eventi interrotti. DynamoDB è generalmente OpenSearch meno strutturato di Service ed è sempre possibile che accada qualcosa di inaspettato. Con una coda di lettere non scritte, è possibile ripristinare singoli eventi e persino automatizzare il processo di ripristino. Questo ti aiuterà a evitare di dover ricostruire l'intero indice.

Imposta sempre avvisi che il ritardo di replica non supera l'importo previsto. In genere è lecito attendere un minuto senza che l'avviso sia troppo rumoroso. Questo può variare a seconda dell'intensità del traffico di scrittura e delle impostazioni della OpenSearch Compute Unit (OCU) sulla pipeline.

Se il ritardo di replica supera le 24 ore, lo stream inizierà a interrompere gli eventi e avrai problemi di precisione, a meno che non esegui una ricostruzione completa dell'indice da zero.

Usa la scalabilità automatica per le pipeline per aumentare o ridurre la scalabilità per adattarsi OCUs al meglio al carico di lavoro.

Per le tabelle di throughput assegnate senza ridimensionamento automatico, consigliamo di impostare l'impostazione in OCUs base alle unità di capacità di scrittura (WCUs) divise per 1000. Imposta il minimo su 1 al di OCU sotto di tale importo (ma almeno 1) e imposta il massimo su almeno 1 al di OCU sopra di tale importo.

Per le tabelle di throughput assegnate con scalabilità automatica, consigliamo di impostare in OCUs base al valore minimo e massimoWCUs, diviso per 1000. Imposta il minimo su 1 al di OCU sotto del minimo di DynamoDB e imposta il massimo su almeno OCU 1 al di sopra del massimo di DynamoDB.

Per le tabelle di throughput su richiesta, consigliamo di impostare in OCUs base al picco e alla valle tipici delle unità di richiesta di scrittura al secondo. Potrebbe essere necessario calcolare la media su un periodo di tempo più lungo, a seconda dell'aggregazione disponibile. Imposta il minimo su 1 al di OCU sotto del minimo di DynamoDB e imposta il massimo su almeno OCU 1 al di sopra del massimo di DynamoDB.

Segui le best practice per scalare gli indici dei servizi di destinazione. OpenSearch Se gli indici sono sottodimensionati, l'acquisizione da DynamoDB rallenterà e potrebbe causare ritardi.