airflow.providers.opensearch.log.os_response

模块内容

AttributeList

辅助类,用于提供对 List 对象的类似属性的访问。

AttributeDict

辅助类,用于提供对 Dictionary 对象的类似属性的访问。

Hit

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

HitMeta

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

OpensearchResponse

OpensearchResponse 类用于管理和访问来自 Opensearch 搜索的响应。

class airflow.providers.opensearch.log.os_response.AttributeList(_list)[source]

辅助类,用于提供对 List 对象的类似属性的访问。

__getitem__(k)[source]

从列表中检索一个项目或一个切片。如果该项目是一个字典,它将被包装在 AttributeDict 中。

__iter__()[source]

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

__bool__()[source]

检查列表是否非空。

class airflow.providers.opensearch.log.os_response.AttributeDict(d)[source]

辅助类,用于提供对 Dictionary 对象的类似属性的访问。

__getattr__(attr_name)[source]

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

__getitem__(key)[source]

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

to_dict()[source]
class airflow.providers.opensearch.log.os_response.Hit(document)[source]

基类:AttributeDict

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

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

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

基类:AttributeDict

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

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

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

基类:AttributeDict

OpensearchResponse 类用于管理和访问来自 Opensearch 搜索的响应。

可以直接迭代此类以访问响应中的命中。使用整数或切片索引类实例也将访问命中。如果响应中有任何命中,该类也会评估为 True。

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

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

property hits: list[Hit][source]

此属性提供对 Opensearch 响应的命中(即结果)的访问。

命中表示为 Hit 实例的 AttributeList,它允许轻松地对命中数据进行类似属性的访问。

命中是延迟加载的,这意味着在访问此属性之前不会对其进行处理。首次访问时,会使用关联的 Search 实例(即来自 ElasticsearchTaskHandler 类的实例)的 _get_result 方法处理响应中的命中数据,并存储结果以供将来访问。

每个命中还包括响应的“hits”字段中存在的所有其他数据,可以作为命中的属性进行访问。

__iter__()[source]

提供对 Elasticsearch 响应中命中的迭代器。

__getitem__(key)[source]

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

__bool__()[source]

评估 Elasticsearch 响应中命中的存在。

此条目是否有帮助?