Создание разделенной запятой строки из словаря в Ansible - PullRequest
0 голосов
/ 03 сентября 2018

Я хочу написать роль Ansible, чтобы иметь возможность alter заданную тему Кафки. Я использую словарь пар ключ / значение.

Модуль command затем используется для выполнения сценария Kafka, который принимает строку значений, разделенных запятыми. Например, используйте app_kafka_topic список:

---
app_kafka_topic:
    cleanup.policy      :
    - "delete"
    retention.ms        :
    - "146800000"
    partitions          :
    - "6"
    replication-factor  :
    - "2"

и создайте string:

"cleanup.policy = удаление, retention.ms = 146800000, перегородки = 6, репликация-фактор = 2"

Это то, что я имею до сих пор.

- name: Reading the Default Topic Properties
  set_fact:
    app_kafka_topic_properties_dicts: |
        {% set res = [] -%}
        {% for key in app_kafka_topic.keys() -%}
           {% for value in app_kafka_topic[key] -%}
            {% set ignored = res.extend([{'topic_property': key, 'value':value}]) -%}
           {%- endfor %}
        {%- endfor %}
        {{ res }}

- name: Create Topic with Default Properties
  command: "{{ kafka_bin_dir }}/{{ kafka_config_script }}
            --zookeeper {{ prefix }}-kafka-{{ Kafka_node }}.{{ DNSDomain}}:{{ zookeeper_port }}
            --entity-type topics
            --alter
            --entity-name {{ kafka_topic }}
            --add-config
            {{ properties }}"
  with_items: "{{ app_kafka_topic_properties_dicts }}"
  register: createdTopic
  vars:
    properties: |-
      {% for key in app_kafka_topic.keys() %}
      {% for value in app_kafka_topic[key] %}
       "{{ key }}={{ value }}"
      {%- endfor %}
      {%- endfor %}

Однако переменная properties не объединяет значения до конца строки. Есть ли способ добавить значения в строку и разделить их запятой?

1 Ответ

0 голосов
/ 03 сентября 2018

Это код, который вы ищете?

play.yml

- hosts: localhost
  gather_facts: no
  vars:
    string: ""
    app_kafka_topic:
      cleanup.policy      :
      - "delete"
      retention_ms        :
      - "146800000"
      partitions          :
      - "6"
      replication_factor  :
      - "2"
  tasks:
    - set_fact:
        string: "{{ string }}{{ (index > 0)|ternary(',','') }}{{ item.key }}={{ item.value[0] }}"
      loop: "{{  app_kafka_topic|dict2items }}"
      loop_control:
        index_var: index
    - debug:
        var: string

$ ansible-playbook play.yml | grep string

"string": "retention_ms=146800000,cleanup.policy=delete,replication_factor=2,partitions=6"
...