• 主页
• airflow.providers.elasticsearch
• airflow.providers.elasticsearch.log
• airflow.providers.elasticsearch.log.es_response

airflow.providers.elasticsearch.log.es_response

类

AttributeList	提供类似属性访问 List 对象 的辅助类。
AttributeDict	提供类似属性访问 Dictionary 对象 的辅助类。
Hit	Hit 类用于管理和访问文档中的元素。
HitMeta	HitMeta 类用于管理和访问文档的元数据。
ElasticSearchResponse	ElasticSearchResponse 类用于管理和访问 Elasticsearch 搜索的响应。

模块内容

class airflow.providers.elasticsearch.log.es_response.AttributeList(_list)

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

__getitem__(k)

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

__iter__()

提供列表或字典的迭代器。

__bool__()

检查列表是否非空。

class airflow.providers.elasticsearch.log.es_response.AttributeDict(d)

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

__getattr__(attr_name)

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

__getitem__(key)

使用键从字典中检索项。

to_dict()

class airflow.providers.elasticsearch.log.es_response.Hit(document)

基类: AttributeDict

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

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

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

基类: AttributeDict

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

该类继承自 AttributeDict 类，并提供属性式访问其元素。

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

基类: AttributeDict

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

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

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

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

__iter__()

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

__getitem__(key)

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

__bool__()

评估 Elasticsearch 响应中是否存在 hits。

property hits: list[Hit]

此属性提供对 Elasticsearch 响应中的 hits（即结果）的访问。

hits 被表示为 Hit 实例的 AttributeList，这允许轻松、属性式地访问 hit 数据。

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

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

上一页 下一页

此条目有帮助吗？