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