• 主页
• airflow.providers.opensearch
• airflow.providers.opensearch.log
• airflow.providers.opensearch.log.os_response

airflow.providers.opensearch.log.os_response

类

AttributeList	提供类似属性访问列表对象的辅助类。
AttributeDict	提供类似属性访问字典对象的辅助类。
Hit	Hit 类用于管理和访问文档中的元素。
HitMeta	HitMeta 类用于管理和访问文档的元数据。
OpensearchResponse	OpensearchResponse 类用于管理和访问 OpenSearch 搜索的响应。

模块内容

class airflow.providers.opensearch.log.os_response.AttributeList(_list)

提供类似属性访问列表对象的辅助类。

__getitem__(k)

从列表中检索一个项目或切片。如果项目是一个字典，则将其包装在 AttributeDict 中。

__iter__()

为列表或字典提供一个迭代器。

__bool__()

检查列表是否非空。

class airflow.providers.opensearch.log.os_response.AttributeDict(d)

提供类似属性访问字典对象的辅助类。

__getattr__(attr_name)

从字典中按属性检索一个项目。

__getitem__(key)

使用键从字典中检索一个项目。

to_dict()

class airflow.providers.opensearch.log.os_response.Hit(document)

基类: AttributeDict

Hit 类用于管理和访问文档中的元素。

它继承自 AttributeDict 类，并提供对其元素的类似属性的访问，类似于字典。

class airflow.providers.opensearch.log.os_response.HitMeta(document, exclude=('_source', '_fields'))

基类: AttributeDict

HitMeta 类用于管理和访问文档的元数据。

此类继承自 AttributeDict 类，并提供对其元素的类似属性的访问。

class airflow.providers.opensearch.log.os_response.OpensearchResponse(search, response, doc_class=None)

基类: AttributeDict

OpensearchResponse 类用于管理和访问 OpenSearch 搜索的响应。

此类可以直接迭代以访问响应中的命中项（hits）。使用整数或切片对类实例进行索引也将访问命中项。如果响应中有任何命中项，则类也评估为 True。

hits 属性返回响应中的命中项的 AttributeList，如果提供了 doc_class，则每个命中项都会转换为 doc_class 的一个实例。

response 参数存储由 Elasticsearch 客户端 search 方法返回的字典。

__iter__()

提供一个迭代器，遍历 Elasticsearch 响应中的命中项。

__getitem__(key)

从 Elasticsearch 响应中检索特定的命中项或命中项切片。

__bool__()

评估 Elasticsearch 响应中是否存在命中项。

property hits: list[Hit]

此属性提供对 OpenSearch 响应中的命中项（即结果）的访问。

命中项表示为 Hit 实例的 AttributeList，这使得可以方便地以类似属性的方式访问命中项数据。

命中项是延迟加载的，这意味着在访问此属性之前不会处理它们。首次访问时，使用关联的 Search 实例（即 ElasticsearchTaskHandler 类的一个实例）的 _get_result 方法处理来自响应的命中项数据，并将结果存储以供将来访问。

每个命中项还包括响应的“hits”字段中存在的所有附加数据，这些数据可以作为命中项的属性进行访问。

上一个 下一个

此条目是否有用？