`tests.system.opensearch.example_opensearch`¶

模組內容¶

類別¶

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

函數¶

load_connections()

屬性¶

`DAG_ID`
`INDEX_NAME`
`default_args`
`create_index`
`test_run`

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.default_args[source]¶

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

基底類別： opensearchpy.helpers.document.Document

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

class Index[source]¶

name[source]¶

log_group_id[source]¶

logger[source]¶

message[source]¶

save(**kwargs)[source]¶

將文件儲存到 opensearch 中。如果文件不存在，則會建立文件，否則會覆寫文件。如果此操作導致建立新文件，則傳回 True。

參數

index – 要使用的 opensearch 索引，如果 Document 與索引關聯，則可以省略。
using – 要使用的連線別名，預設為 'default'
validate – 設定為 False 以跳過驗證文件
skip_empty – 如果設定為 False，將導致空值 (None、[]、{}) 保留在文件中。否則這些值將被移除，因為它們在 opensearch 中沒有任何區別。
return_doc_meta – 設定為 True 以從更新 API 呼叫傳回所有元數據，而不是僅傳回操作結果

任何其他關鍵字引數都將不變地傳遞給 OpenSearch.index。

:return 操作結果 created/updated

tests.system.opensearch.example_opensearch.load_connections()[source]¶

tests.system.opensearch.example_opensearch.create_index[source]¶

tests.system.opensearch.example_opensearch.test_run[source]¶

此條目是否有幫助？