安全审计>> metricsworker>> 返回
项目作者： ottogiron

项目描述 ：
Metrics workers processor
高级语言： Go
项目地址: git://github.com/ottogiron/metricsworker.git
创建时间： 2017-04-06T04:19:06Z
项目社区：https://github.com/ottogiron/metricsworker
开源协议：
下载


Metrics Workers

A set of workers processing metrics from RabbitMQ.

Available worker are:

  • distinctName
  • hourlyLog
  • accountName

Note: Workers consume and process metrics from a single queue concurrently.

Build Status
GoDoc
Go Report Card

Install

Download and install from the releases page

Dependencies

  • RabbitMQ
  • Redis
  • MongoDB
  • PostgreSQL

For testing purposes you can run the docker compose development file docker-compose.dev.yml

  1. docker-compose -f docker-compose.dev.yml up -d

Example

  2. mworker --concurrency=1 \
  3.     --wait-timeout=600 \
  4.     --rabbit-uri=amqp://guest:guest@localhost:5672 \
  5.     --rabbit-queue_name=hello \
  6.     --rabbit-consumer_auto_ack=true \
  7.     --rabbit-exchange="test-exchange" \
  8.     --rabbit-routing_key="test-key"

Usage

  1. mworker [flags]
  3. Flags :
  4. -concurrency int
  5.         Number of concurrent set of workers running (default 1)
  6.   -mongo-events-db string
  7.         mongo events database (default "events")
  8.   -mongo-host string
  9.         mongo host localhost (default "localhost")
  10.   -postgres-db string
  11.         postgres database (default "postgres")
  12.   -postgres-host string
  13.         postgres host (default "localhost")
  14.   -postgres-password string
  15.         postgres password (default "mysecret")
  16.   -postgres-user string
  17.         postgres user (default "postgres")
  18.   -rabbit-binding_wait
  19.         Binding wait
  20.   -rabbit-consumer_auto_ack
  21.         Consumer Auto ACK
  22.   -rabbit-consumer_no_local
  23.         Consumer no local
  24.   -rabbit-consumer_no_wait
  25.         Consumer no wait
  26.   -rabbit-consumer_tag string
  27.         Consumer tag
  28.   -rabbit-exchange string
  29.         Exchange name. If exchange name is empty all other exchange flags are ignored
  30.   -rabbit-exchange_delete_when_complete
  31.         Exchange delete when complete
  32.   -rabbit-exchange_durable
  33.         Exchange durable (default true)
  34.   -rabbit-exchange_internal
  35.         Exchange internal
  36.   -rabbit-exchange_no_wait
  37.         Exchange no wait
  38.   -rabbit-exchange_type string
  39.         Exchange type - direct|fanout|topic|x-custom (default "direct")
  40.   -rabbit-queue_delete_when_used
  41.         Queue delete queue when used
  42.   -rabbit-queue_durable
  43.         Queue durable
  44.   -rabbit-queue_exclusive
  45.         Queue exclusive
  46.   -rabbit-queue_name string
  47.         Rabbit queue name (default "hello-queue")
  48.   -rabbit-queue_no_wait
  49.         Queue no wait
  50.   -rabbit-routing_key string
  51.         Routing Key
  52.   -rabbit-uri string
  53.         Rabbit instance uri e.g. amqp://guest:guest@localhost:5672/ (default "amqp://guest:guest@localhost:5672/")
  54.   -redis-address string
  55.         Redis address example localhost:6779  (default "localhost:6379")
  56.   -redis-db int
  57.         Redis DB
  58.   -wait-timeout int
  59.         Time to wait in miliseconds until new jobs are available in rabbit  (default 500)