如何将Ansible Playbook的stdout_lines输出保存为指定格式CSV文件

要把你采集的服务器IP、运行时长、磁盘分区和磁盘空间指标保存为CSV文件，你可以通过以下两种方案修改Playbook，实现数据格式化与文件生成：

方案1：快速转换控制台格式为CSV #

这个方案直接将控制台输出的空格分隔格式转换为逗号分隔的CSV，保留原输出结构，同时添加服务器基本信息作为表头：

---
- name: Collect server metrics and export to CSV
  hosts: test_host
  gather_facts: true

  tasks:
    # 采集服务器IP
    - name: Get remote node IP address
      ansible.builtin.command: hostname -i
      register: ip_raw
    - name: Extract target IP
      ansible.builtin.set_fact:
        server_ip: "{{ ip_raw.stdout.split()[1] }}"

    # 采集运行时长
    - name: Get system uptime
      ansible.builtin.command: uptime
      register: uptime_raw
    - name: Format uptime output
      ansible.builtin.set_fact:
        server_uptime: "{{ uptime_raw.stdout.split(',')[0] }}"

    # 采集磁盘分区信息并转为CSV格式
    - name: Get lsblk data
      ansible.builtin.command: lsblk
      register: lsblk_raw
    - name: Convert lsblk to CSV lines
      ansible.builtin.set_fact:
        lsblk_csv_lines: "{{ lsblk_raw.stdout_lines | map('regex_replace', '\\s+', ',') | list }}"

    # 采集磁盘空间信息并转为CSV格式
    - name: Get df data
      ansible.builtin.command: df -h
      register: df_raw
    - name: Convert df to CSV lines
      ansible.builtin.set_fact:
        df_csv_lines: "{{ df_raw.stdout_lines | map('regex_replace', '\\s+', ',') | list }}"

    # 拼接完整CSV内容
    - name: Assemble CSV content
      ansible.builtin.set_fact:
        csv_content: |
          # Server Basic Information
          Server IP,Uptime
          {{ server_ip }},{{ server_uptime }}

          # Disk Partition Details (lsblk)
          {{ lsblk_csv_lines | join('\n') }}

          # Disk Usage Details (df -h)
          {{ df_csv_lines | join('\n') }}

    # 将CSV保存到控制节点
    - name: Save CSV to control node
      ansible.builtin.copy:
        content: "{{ csv_content }}"
        dest: "./server_metrics_{{ inventory_hostname }}.csv"
        mode: '0644'

关键说明： #

• 格式转换：使用regex_replace('\\s+', ',')将原输出中的连续空格替换为逗号，满足CSV的分隔要求。
• 内容拼接：通过set_fact将不同模块的采集结果按逻辑分块拼接，添加注释区分不同指标类别。
• 文件保存：使用copy模块将生成的CSV内容写入控制节点本地文件，文件名包含主机名方便识别。

方案2：结构化CSV（每条磁盘记录关联服务器信息） #

如果需要更适合数据分析的结构化CSV，可让每条磁盘分区/空间记录都携带服务器IP和运行时长：

---
- name: Collect structured server metrics to CSV
  hosts: test_host
  gather_facts: true

  tasks:
    # 采集并处理服务器IP
    - name: Get remote node IP address
      ansible.builtin.command: hostname -i
      register: ip_raw
    - name: Extract target IP
      ansible.builtin.set_fact:
        server_ip: "{{ ip_raw.stdout.split()[1] }}"

    # 采集并处理运行时长
    - name: Get system uptime
      ansible.builtin.command: uptime
      register: uptime_raw
    - name: Format uptime output
      ansible.builtin.set_fact:
        server_uptime: "{{ uptime_raw.stdout.split(',')[0] }}"

    # 处理磁盘分区为结构化CSV
    - name: Get lsblk data
      ansible.builtin.command: lsblk
      register: lsblk_raw
    - name: Generate structured lsblk CSV
      ansible.builtin.set_fact:
        lsblk_structured: |
          Server IP,Uptime,{{ lsblk_raw.stdout_lines[0] | regex_replace('\\s+', ',') }}
          {% for line in lsblk_raw.stdout_lines[1:] %}
          {{ server_ip }},{{ server_uptime }},{{ line | regex_replace('\\s+', ',') }}
          {% endfor %}

    # 处理磁盘空间为结构化CSV
    - name: Get df data
      ansible.builtin.command: df -h
      register: df_raw
    - name: Generate structured df CSV
      ansible.builtin.set_fact:
        df_structured: |
          Server IP,Uptime,{{ df_raw.stdout_lines[0] | regex_replace('\\s+', ',') }}
          {% for line in df_raw.stdout_lines[1:] %}
          {{ server_ip }},{{ server_uptime }},{{ line | regex_replace('\\s+', ',') }}
          {% endfor %}

    # 拼接并保存结构化CSV
    - name: Assemble structured CSV content
      ansible.builtin.set_fact:
        csv_content: "{{ lsblk_structured }}\n\n{{ df_structured }}"

    - name: Save structured CSV
      ansible.builtin.copy:
        content: "{{ csv_content }}"
        dest: "./structured_server_metrics_{{ inventory_hostname }}.csv"
        mode: '0644'

关键说明： #

• 结构化关联：使用Jinja2循环，将服务器IP和运行时长作为前缀添加到每条磁盘记录中，方便后续多服务器数据合并分析。
• 表头复用：直接复用原命令输出的表头，确保CSV字段与数据一一对应。

注意事项 #

• 如果服务器输出中存在包含空格的字段（如特殊挂载点），可修改正则替换逻辑，用双引号包裹字段：regex_replace('(\\S+)\\s+', '\"\\1\",')，避免字段拆分错误。
• 优先使用command模块替代shell模块，减少shell依赖，提升Playbook的兼容性与安全性。

内容的提问来源于stack exchange，提问作者saravanan jothilingam