ansible-nsq

NSQ 实时分布式消息平台的 Ansible 安装角色。

该角色通过 systemd 管理 NSQ。支持以下平台：

• CentOS: >7
• Ubuntu: >16.04 (xenial)

安装

使用以下命令安装：

ansible-galaxy install ernestas-poskus.ansible-nsq

示例剧本

- name: 安装 NSQ
  hosts: all
  sudo: yes
  roles:
    - role: ernestas-poskus.ansible-nsq

多节点设置示例

- name: 安装 NSQ
  hosts: nsqs
  sudo: yes
  roles:
    - role: ernestas-poskus.ansible-nsq
      nsq_lookupd_tcp_addresses: "{{ groups['nsqs']|map('extract', hostvars, ['ansible_eth1', 'ipv4', 'address'])|list }}"
      nsq_lookupd_http_addresses: "{{ groups['nsqs']|map('extract', hostvars, ['ansible_eth1', 'ipv4', 'address'])|list }}"

对于多节点设置，更新 nsqd['broadcast_address'] 或配置您的主机以便它们可以相互找到。

要求

无。

角色变量

---
# ansible-nsq 的默认文件

nsq_nsqd_install: true
nsq_nsqadmin_install: true
nsq_nsqlookupd_install: true

nsq_owner: root
nsq_group: root

nsq_version: 0.3.8
nsq_go_version: go1.6.2
nsq_arch: linux-amd64

nsq_install_directory: /opt

nsq_config_directory: /etc/nsq
nsq_config_directory_mode: 0644

nsq_data_directory: /var/lib/nsq
nsq_data_directory_mode: 0750

nsq_binaries:
  - nsq_pubsub
  - nsq_stat
  - nsq_tail
  - nsq_to_file
  - nsq_to_http
  - nsq_to_nsq
  - to_nsq

nsq_network_interface: "{{ ansible_default_ipv4.interface }}"
nsq_network_ip_protocol: 'ipv4'

nsq_network_address: "{{ hostvars[inventory_hostname]['ansible_' + nsq_network_interface][nsq_network_ip_protocol]['address'] }}"

nsq_lookupd_tcp_port: 4160
nsq_lookupd_http_port: 4161

nsq_lookupd_tcp_addresses:
  - "{{ nsq_network_address }}"

nsq_lookupd_http_addresses:
  - "{{ nsq_network_address }}"

nsq_nsqlookupd:
  broadcast_address: "{{ ansible_hostname }}"
  http_address: "{{ nsq_network_address }}:{{ nsq_lookupd_http_port }}"
  inactive_producer_timeout: 300s
  tcp_address: "{{ nsq_network_address }}:{{ nsq_lookupd_tcp_port }}"
  tombstone_lifetime: 45s

nsq_nsqd:
  auth_http_address:
  broadcast_address: "{{ ansible_hostname }}"
  data_path: "{{ nsq_data_directory }}"
  deflate: true
  e2e_processing_latency_percentile:
  e2e_processing_latency_window_time: 600s
  http_address: "{{ nsq_network_address }}:4151"
  https_address: "{{ nsq_network_address }}:4152"
  max_body_size: 5242880
  max_bytes_per_file: 104857600
  max_deflate_level: 6
  max_heartbeat_interval: 60s
  max_msg_size: 1048576
  max_msg_timeout: 900s
  max_output_buffer_size: 65536
  max_output_buffer_timeout: 1s
  max_rdy_count: 2500
  max_req_timeout: 3600s
  mem_queue_size: 10000
  msg_timeout: 60s
  snappy: true
  statsd_address:
  statsd_interval: 60s
  statsd_mem_stats: true
  statsd_prefix: 'nsq.%s'
  sync_every: 2500
  sync_timeout: 2s
  tcp_address: "{{ nsq_network_address }}:4150"
  tls_cert:
  tls_client_auth_policy:
  tls_key:
  tls_min_version: 'tls1.0'
  tls_required: false
  tls_root_ca_file:
  worker_id: 255

nsq_nsqadmin:
  graphite_url:
  http_address: "{{ nsq_network_address }}:4171"
  http_client_tls_cert:
  http_client_tls_insecure_skip_verify:
  http_client_tls_key:
  http_client_tls_root_ca_file:
  notification_http_endpoint:
  proxy_graphite:
  statsd_counter_format: 'stats.counters.%s.count'
  statsd_gauge_format: 'stats.gauges.%s'
  statsd_interval: '60s'
  statsd_prefix: 'nsq.%s'
  template_dir:

依赖

无。

测试

您需要安装 Ruby 和 VirtualBox 以便在虚拟机中进行测试。

gem install bundler
bundle install
bundle exec kitchen test

=======

许可证

版权 (c) 2016, Ernestas Poskus 保留所有权利。

源代码和二进制形式的重新分发和使用，无论是否修改，均允许，只要满足以下条件：

• 源代码的重新分发必须保留上述版权声明、本条件列表和以下免责声明。

• 以二进制形式重新分发必须在随分发提供的文档和/或其他材料中重现上述版权声明、本条件列表和以下免责声明。

• 没有获得特定的书面许可，不得使用 ansible-nsq 或其贡献者的名称来支持或推广从该软件派生的产品。

该软件由版权持有人和贡献者按“原样”提供，且不提供任何明示或暗示的保证，包括但不限于适销性和特定目的的隐含保证。在任何情况下，版权持有人或贡献者均不对因使用该软件而产生的任何直接、间接、偶然、特殊、典型或后果性损害负责，无论是基于合同、严格责任或侵权（包括过失或其他行为）。

作者信息

Twitter: @ernestas_poskus