Trasformazione degli indici in Amazon Service OpenSearch

Mentre i processi di aggregazione degli indici consentono di ridurre la granularità dei dati raggruppando i vecchi dati in indici condensati, i processi di trasformazione consentono di creare una visualizzazione riepilogativa diversa dei dati incentrata su determinati campi, in modo da poterli visualizzare o analizzare in diversi modi.

Le trasformazioni degli indici dispongono di un'interfaccia utente Dashboards e di un'API REST. OpenSearch La funzionalità richiede la OpenSearch versione 1.0 o successiva.

Nota

Questa documentazione fornisce una breve panoramica delle trasformazioni degli indici per aiutarti a iniziare a utilizzarli su un dominio Amazon OpenSearch Service. Per una documentazione completa e un riferimento all'API REST, consulta Index transforms nella documentazione open source OpenSearch .

Creazione di un processo di trasformazione dell'indice

Se non disponi di dati nel cluster, utilizza i dati di volo di esempio all'interno di OpenSearch Dashboards per provare Transform Jobs. Dopo aver aggiunto i dati, avvia OpenSearch Dashboards. Quindi scegliere Gestione degli indici, Processo di trasformazione e Crea processo di trasformazione.

Passaggio 1: scegli gli indici

Nella sezione Indici, selezionare l'indice di origine e di destinazione. È possibile selezionare un indice di destinazione esistente o crearne uno nuovo specificando un nome.

Se desideri trasformare solo un sottoinsieme dell'indice di origine, scegli Aggiungi filtro dati e usa la OpenSearch query DSL per specificare un sottoinsieme dell'indice di origine.

Fase 2: Scelta dei campi

Dopo aver scelto gli indici, scegli i campi che desideri utilizzare nel processo di trasformazione e se utilizzare raggruppamenti o aggregazioni.

• È possibile utilizzare i raggruppamenti per inserire i dati in bucket separati nell'indice trasformato. Ad esempio, se si desidera raggruppare tutte le destinazioni aeroportuali all'interno dei dati di volo di esempio, raggruppare il campo DestAirportID in un campo di destinazione del campo DestAirportID_terms e sarà possibile trovare gli ID dell'aeroporto raggruppati nell'indice trasformato al termine del processo di trasformazione.

• D'altra parte, le aggregazioni consentono di eseguire calcoli semplici. Ad esempio, è possibile includere un'aggregazione nel processo di trasformazione per definire un nuovo campo di sum_of_total_ticket_price che calcola la somma di tutti i biglietti aerei. Quindi è possibile analizzare i nuovi dati nell'indice trasformato.

Fase 3: Specifica di una pianificazione

I processi di trasformazione sono abilitati per impostazione predefinita e sono eseguiti in base a pianificazioni. Per trasforma intervallo di esecuzione, specificare un intervallo in minuti, ore o giorni.

Fase 4: Revisione e monitoraggio

Rivedere la configurazione e selezionare Crea. Quindi monitorare la colonna Stato del processo di trasformazione.

Fase 5: Ricerca nell'indice di destinazione

Una volta terminato il processo, è possibile utilizzare l'API _search standard per cercare l'indice di destinazione.

Ad esempio, dopo aver eseguito un processo di trasformazione che trasforma i dati di volo in base al campo DestAirportID, è possibile eseguire la seguente richiesta per restituire tutti i campi che hanno un valore SFO:

GET target_index/_search
{
  "query": {
    "match": {
      "DestAirportID_terms" : "SFO"
    }
  }
}