“Un dati dati ElasticSearch si riferisce a una raccolta di indici generati automaticamente che vengono utilizzati per archiviare registri, metriche, dati di traccia e altri dati generati automaticamente. Un flusso di dati richiede un modello di indice corrispondente contenente mappature e impostazioni per configurare gli indici.
Questo articolo coprirà i fondamenti del lavoro con i flussi di dati di ElaSticSearch utilizzando l'API FETCH Data Stream."
Esploriamo.
Richiedi sintassi
Di seguito mostra la sintassi per l'API di flusso di dati.
Get /_data_stream /
Parametri del percorso:
Esempio
Creare flusso di dati
Metti my_data_stream/_bulk
"creare":
"@timestamp": "2022-09-06t16: 21: 15.000Z "," messaggio ":" 192.168.0.101 - Accesso "
"creare":
"@timestamp": "2022-09-06t16: 25: 42.000Z "," messaggio ":" 192.168.0.110 - Accesso "
Post my_data_stream/_doc
"@timestamp": "2022-09-06t16: 21: 15.000Z ",
"Messaggio": "192.168.0.101 - - accesso "
Produzione
"preso": 3,
"Errori": Falso,
"elementi": [
"creare":
"_index": "My-Data-Stream",
"_id": "ot6aximb1yf5vqfa_scu",
"_version": 1,
"Risultato": "Creato",
"_Shards":
"totale": 2,
"successo": 2,
"fallito": 0
,
"_seq_no": 3,
"_primary_term": 1,
"Status": 201
,
"creare":
"_index": "My-Data-Stream",
"_id": "oj6aximb1yf5vqfa_scu",
"_version": 1,
"Risultato": "Creato",
"_Shards":
"totale": 2,
"successo": 2,
"fallito": 0
,
"_seq_no": 4,
"_primary_term": 1,
"Status": 201
"
"_index": "My-Data-Stream",
"_id": "oz6bximb1yf5vqfaviem",
"_version": 1,
"Risultato": "Creato",
"_Shards":
"totale": 2,
"successo": 2,
"fallito": 0
,
"_seq_no": 5,
"_primary_term": 1
Recuperare il flusso di dati
Curl -xget "http: // localhost: 9200/my_data_stream" -h "kbn -xsrf: reporting"Produzione
"my_data_stream":
"Aliases": ,
"Mappings":
"proprietà":
"Messaggio":
"tipo": "testo",
"campi":
"parola chiave":
"Digita": "Parola chiave",
"Ignore_above": 256
,
"timestamp":
"tipo": "testo",
"campi":
"parola chiave":
"Digita": "Parola chiave",
"Ignore_above": 256
,
"Nome utente":
"tipo": "testo",
"campi":
"parola chiave":
"Digita": "Parola chiave",
"Ignore_above": 256
,
"impostazioni":
"indice":
"Routing":
"Allocazione":
"includere":
"_tier_preference": "data_content"
,
"NUMBER_OF_SHARDS": "1",
"fornito_name": "my_data_stream",
"Creation_date": "1663703715012",
"Number_of_replicas": "1",
"Uuid": "offuehvkrn6rk1ql2rpreg",
"Versione":
"Creato": "8040199"
FINE
In questo post, abbiamo discusso di come utilizzare l'API di flusso di dati ElaSticSearch per recuperare informazioni dettagliate sui flussi di dati disponibili nel cluster.
Grazie per la lettura e la codifica felice!!