tests.system.opensearch.example_opensearch¶

屬性¶

用於在 opensearch 中持久化文件的模型類。

tests.system.opensearch.example_opensearch.DAG_ID = 'example_opensearch'[source]¶

tests.system.opensearch.example_opensearch.INDEX_NAME = 'example_index'[source]¶

類 tests.system.opensearch.example_opensearch.LogDocument(meta=None, **kwargs)[source]¶

繼承自: opensearchpy.helpers.document.Document

用於在 opensearch 中持久化文件的模型類。

save(**kwargs)[source]¶

將文件儲存到 opensearch 中。如果文件不存在，則建立；否則覆蓋。如果此操作導致建立了新文件，則返回 True。

引數:

index – 要使用的 opensearch 索引，如果 Document 已關聯索引，則可以省略。
using – 要使用的連線別名，預設為 'default'
validate – 設定為 False 可跳過驗證文件
skip_empty – 如果設定為 False，將保留文件中的空值（None、[]、{}）。否則，這些值將被剝離，因為它們在 opensearch 中不起作用。
return_doc_meta – 設定為 True 可返回 update API 呼叫中的所有元資料，而不是僅返回操作結果

任何額外的關鍵字引數將原樣傳遞給 OpenSearch.index。

:return 操作結果 created/updated