`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]¶

此条目是否有帮助？