tests.system.opensearch.example_opensearch

属性

DAG_ID

INDEX_NAME

default_args

create_index

test_run

LogDocument

用于在 opensearch 中持久化文档的模型类。

函数

load_connections()

模块内容

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]
tests.system.opensearch.example_opensearch.LogDocument(meta=None, **kwargs)[source]

继承自: opensearchpy.helpers.document.Document

用于在 opensearch 中持久化文档的模型类。

log_group_id[source]
logger[source]
message[source]
Index[source]
name = 'example_index'[source]
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

tests.system.opensearch.example_opensearch.load_connections()[source]
tests.system.opensearch.example_opensearch.create_index[source]
tests.system.opensearch.example_opensearch.test_run[source]

这条目有帮助吗?