airflow.providers.elasticsearch.log.es_response

模块内容

AttributeList

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

AttributeDict

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

Hit

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

HitMeta

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

ElasticSearchResponse

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

class airflow.providers.elasticsearch.log.es_response.AttributeList(_list)[source]

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

__getitem__(k)[source]

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

__iter__()[source]

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

__bool__()[source]

检查列表是否非空。

class airflow.providers.elasticsearch.log.es_response.AttributeDict(d)[source]

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

__getattr__(attr_name)[source]

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

__getitem__(key)[source]

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

to_dict()[source]
class airflow.providers.elasticsearch.log.es_response.Hit(document)[source]

基类: AttributeDict

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

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

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

基类: AttributeDict

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

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

class airflow.providers.elasticsearch.log.es_response.ElasticSearchResponse(search, response, doc_class=None)[source]

基类: AttributeDict

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

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

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

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

property hits: list[Hit][source]

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

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

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

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

__iter__()[source]

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

__getitem__(key)[source]

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

__bool__()[source]

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

此条目是否有帮助?