在Python中使用ansible.utils.display.Display()函数将Ansible任务结果发送到Elasticsearch索引。

在Python中使用ansible.utils.display.Display()函数将Ansible任务结果发送到Elasticsearch索引，可以通过以下步骤实现：

1. 安装所需的Python库：

pip install elasticsearch ansible

2. 创建一个Python脚本，导入所需的模块和库：

import json
from ansible.utils.display import Display
from elasticsearch import Elasticsearch

3. 初始化Display对象，并覆盖其display方法，将任务结果收集到一个列表中：

class ElasticsearchDisplay(Display):
    def __init__(self):
        super(ElasticsearchDisplay, self).__init__()
        self.results = []

    def display(self, msg):
        self.results.append(json.loads(msg))

4. 创建一个函数来将结果发送到Elasticsearch索引：

def send_to_elasticsearch(index_name, results):
    es = Elasticsearch()

    for result in results:
        es.index(index=index_name, body=result)

5. 使用Ansible运行任务，并将结果发送到Elasticsearch索引：

if __name__ == '__main__':
    display = ElasticsearchDisplay()
    # 设置为使用自定义的显示方法
    display.display = display.display

    # 运行Ansible任务
    # 你的ansible代码...
    # 通过display对象访问结果
    display.results

    # 发送结果到Elasticsearch索引
    send_to_elasticsearch('ansible_results', display.results)

在上述代码中，我们创建了一个ElasticsearchDisplay类，继承自Display类，并覆盖了display方法。在该方法中，我们将Ansible任务的结果以JSON格式解析并添加到来自Elasticsearch的display.results列表中。

然后，我们定义了send_to_elasticsearch函数，该函数使用Python库elasticsearch将结果发送到Elasticsearch索引中。我们通过遍历结果列表，对每个结果使用es.index()方法发送到Elasticsearch。

最后，在__main__函数中，我们初始化ElasticsearchDisplay对象，并使用自定义的display方法运行Ansible任务。然后，我们将结果发送到Elasticsearch索引中。

请注意，在运行此代码之前，确保已安装并正确配置了Elasticsearch，并且Ansible任务返回的结果是符合预期的。