„Elasticsearch DataStream odnosi się do zbioru automatycznie generowanych indeksów używanych do przechowywania dzienników, wskaźników, danych śledzenia i innych automatycznie generowanych danych. Strumień danych wymaga dopasowania szablonu indeksu zawierającego odwzorowania i ustawienia, aby skonfigurować indeksy.
W tym artykule obejmie podstawy pracy ze strumieniami danych ElasticSearch przy użyciu interfejsu API strumienia danych Fetch Data."
Odkryjmy.
Składnia żądania
Poniżej pokazuje składnię interfejsu API strumienia danych GET.
Get /_Data_stream /
Parametry ścieżki:
Przykład
Utwórz strumień danych
Umieść my_data_stream/_bulk
"tworzyć":
„@timestamp”: „2022-09-06T16: 21: 15.000Z ”,„ Message ”:„ 192.168.0.101 - Dostęp ”
"tworzyć":
„@timestamp”: „2022-09-06T16: 25: 42.000Z ”,„ Message ”:„ 192.168.0.110 - dostęp „
Opublikuj my_data_stream/_doc
„@timestamp”: „2022-09-06T16: 21: 15.000Z ",
„Wiadomość”: „192.168.0.101 - - Dostęp ”
Wyjście
„wziął”: 3,
„Błędy”: Fałsz,
"rzeczy": [
"tworzyć":
„_Index”: „My-Data-Stream”,
„_id”: „OT6AXIMB1YF5VQFA_SCU”,
"_wersja 1,
„Wynik”: „stworzony”,
„_Shards”:
„Total”: 2,
„Sukces”: 2,
„nieudany”: 0
,
„_seq_no”: 3,
„_primary_term”: 1,
„Status”: 201
,
"tworzyć":
„_Index”: „My-Data-Stream”,
„_id”: „OJ6AXIMB1YF5VQFA_SCU”,
"_wersja 1,
„Wynik”: „stworzony”,
„_Shards”:
„Total”: 2,
„Sukces”: 2,
„nieudany”: 0
,
„_seq_no”: 4,
„_primary_term”: 1,
„Status”: 201
]
„_Index”: „My-Data-Stream”,
„_id”: „Oz6bximb1yf5vqfaviem”,
"_wersja 1,
„Wynik”: „stworzony”,
„_Shards”:
„Total”: 2,
„Sukces”: 2,
„nieudany”: 0
,
„_seq_no”: 5,
„_primary_term”: 1
Pobierz strumień danych
curl -xget "http: // localhost: 9200/my_data_stream" -h "kbn -xsrf: raportowanie"Wyjście
„my_data_stream”:
"skróty": ,
„Mapowania”:
"nieruchomości":
"wiadomość":
"Wpisz tekst",
„Fields”:
„Słowo kluczowe”:
„Typ”: „Słowo kluczowe”,
„Ignorate_above”: 256
,
"znak czasu":
"Wpisz tekst",
„Fields”:
„Słowo kluczowe”:
„Typ”: „Słowo kluczowe”,
„Ignorate_above”: 256
,
"nazwa użytkownika":
"Wpisz tekst",
„Fields”:
„Słowo kluczowe”:
„Typ”: „Słowo kluczowe”,
„Ignorate_above”: 256
,
„Ustawienia”:
„Indeks”:
"rozgromienie":
„Alokacja”:
"włączać":
„_Tier_Preference”: „data_content”
,
„Number_of_shards”: „1”,
„Dostarczony nazwa_namalna”: „my_data_stream”,
„Creation_date”: „1663703715012”,
„Number_of_replicas”: „1”,
„UUID”: „OFFUEHVKRN6RK1QL2RPREG”,
„Wersja”:
„Created”: „8040199”
Koniec
W tym poście omówiliśmy, jak korzystać z ElasticSearch API STREAM DATE STREAM w celu pobrania szczegółowych informacji o strumieniach danych dostępnych w klastrze.
Dziękujemy za przeczytanie i szczęśliwe kodowanie!!