🥇Nginx json ሎጆችን በቬክተር በመጠቀም ወደ Clickhouse እና Elasticsearch መላክ

የቬክተርየምዝግብ ማስታወሻ ውሂብን፣ መለኪያዎችን እና ክስተቶችን ለመሰብሰብ፣ ለመለወጥ እና ለመላክ የተነደፈ።

በሩስት ቋንቋ የተፃፈ በመሆኑ ከፍተኛ አፈፃፀም እና ዝቅተኛ የ RAM ፍጆታ ከአቻዎቹ ጋር ሲወዳደር ይገለጻል። በተጨማሪም, ከትክክለኛነት ጋር ለተያያዙ ተግባራት ብዙ ትኩረት ተሰጥቷል, በተለይም ያልተላኩ ክስተቶችን በዲስክ እና በፋይል ማሽከርከር ላይ ባለው ቋት ላይ የማዳን ችሎታ.

በሥነ ሕንፃ ቬክተር ከአንድ ወይም ከዚያ በላይ መልዕክቶችን የሚቀበል የክስተት ራውተር ነው። ምንጮች, እንደ አማራጭ በእነዚህ መልዕክቶች ላይ ማመልከት ለውጦች, እና ወደ አንድ ወይም ከዚያ በላይ መላክ የፍሳሽ ማስወገጃዎች.

ቬክተር የፋይልቢት እና ሎግስታሽ ምትክ ነው, በሁለቱም ሚናዎች ውስጥ ሊሠራ ይችላል (ምዝግብ ማስታወሻዎችን መቀበል እና መላክ), በእነሱ ላይ ተጨማሪ ዝርዝሮች ጣቢያ.

በ Logstash ውስጥ ሰንሰለቱ የተገነባው እንደ ግብአት → ማጣሪያ → ውፅዓት ነው ፣ ከዚያ በቬክተር ውስጥ ነው። ምንጮች → ይለወጣል። → መስመጥ

ምሳሌዎች በሰነዶቹ ውስጥ ይገኛሉ.

ይህ መመሪያ የተሻሻለው መመሪያ ነው። Vyacheslav Rakhinsky. የመጀመሪያው መመሪያ ጂኦፕ ማቀናበር አላቸው። ጂኦፕን ከውስጥ አውታረመረብ ስሞክር ቬክተር ስህተት ሰጠኝ።

Aug 05 06:25:31.889 DEBUG transform{name=nginx_parse_rename_fields type=rename_fields}: vector::transforms::rename_fields: Field did not exist field=«geoip.country_name» rate_limit_secs=30

አንድ ሰው ጂኦፕን ማስኬድ ከፈለገ፣ ከዚያ ዋናውን መመሪያ ይመልከቱ Vyacheslav Rakhinsky.

Nginx (የመዳረሻ ምዝግብ ማስታወሻዎች) → ቬክተር (ደንበኛ | Filebeat) → ቬክተር (ሰርቨር | Logstash) → በ Clickhouse ውስጥ እና በተናጠል በ Elasticsearch ውስጥ እናዋቅራለን። 4 አገልጋዮችን አዘጋጅ። ምንም እንኳን 3 አገልጋዮችን ማለፍ ቢቻልም.

መርሃግብሩ እንደዚህ ያለ ነገር ነው.

Selinuxን በሁሉም አገልጋዮችዎ ላይ ያጥፉ

sed -i 's/^SELINUX=.*/SELINUX=disabled/g' /etc/selinux/config
reboot

የኤችቲቲፒ አገልጋይ emulator + መገልገያዎችን በሁሉም አገልጋዮች ላይ ይጫኑ

እንደ HTTP አገልጋይ ኢምፔር እንጠቀማለን። nodejs-stub-አገልጋይ от Maxim Ignatenko

nodejs-stub-አገልጋይ rpm የለውም። ይህ ነው ለእሱ rpm ይፍጠሩ. rpm በመጠቀም ይገነባል። Fedora Copr

የ antonpatsev/nodejs-stub-server ማከማቻ አክል

yum -y install yum-plugin-copr epel-release
yes | yum copr enable antonpatsev/nodejs-stub-server

በሁሉም አገልጋዮች ላይ nodejs-stub-server፣ Apache benchmark እና ስክሪን ተርሚናል multiplexer ጫን

yum -y install stub_http_server screen mc httpd-tools screen

በ /var/lib/stub_http_server/stub_http_server.js ፋይል ውስጥ ያለው የ stub_http_server ምላሽ ሰአቱን ብዙ ምዝግብ ማስታወሻዎች እንዲኖረው አስተካክሏል።

var max_sleep = 10;

stub_http_server እንጀምር።

systemctl start stub_http_server
systemctl enable stub_http_server

Clickhouse መጫን በአገልጋይ 3

ClickHouse የኤስኤስኢ 4.2 መመሪያ ስብስብን ይጠቀማል፣ስለዚህ በሌላ መልኩ ካልተገለጸ በቀር፣ በተጠቀመው ፕሮሰሰር ውስጥ ያለው ድጋፍ ተጨማሪ የስርዓት መስፈርት ይሆናል። የአሁኑ ፕሮሰሰር SSE 4.2 ን የሚደግፍ መሆኑን ለማረጋገጥ ትዕዛዙ እዚህ አለ።

grep -q sse4_2 /proc/cpuinfo && echo "SSE 4.2 supported" || echo "SSE 4.2 not supported"

በመጀመሪያ ኦፊሴላዊውን ማከማቻ ማገናኘት ያስፈልግዎታል:

sudo yum install -y yum-utils
sudo rpm --import https://repo.clickhouse.tech/CLICKHOUSE-KEY.GPG
sudo yum-config-manager --add-repo https://repo.clickhouse.tech/rpm/stable/x86_64

ጥቅሎችን ለመጫን የሚከተሉትን ትዕዛዞችን ያሂዱ

sudo yum install -y clickhouse-server clickhouse-client

በ /etc/clickhouse-server/config.xml ፋይል ውስጥ የአውታረ መረብ ካርዱን እንዲያዳምጥ ክሊክሃውስ-ሰርቨር እንፈቅዳለን።

<listen_host>0.0.0.0</listen_host>

የምዝግብ ማስታወሻውን ከክትትል ወደ ማረም ይለውጡ

ማረም

የማመቅ ቅንጅቶች መደበኛ ናቸው፡

min_compress_block_size  65536
max_compress_block_size  1048576

Zstd መጠበቅን ለማንቃት አወቃቀሩ እንዳይነካ ይመከራል ነገር ግን DDL ን መጠቀም የተሻለ ነው።

በ Google ውስጥ zstd compression በ DDL በኩል እንዴት እንደሚተገበር አላገኘሁም። ስለዚህ እንዳለ ተውኩት።

በ Clickhouse ውስጥ zstd compression የሚጠቀሙ ባልደረቦች - እባክዎ መመሪያዎቹን ያጋሩ።

አገልጋዩን እንደ ዴሞን ለመጀመር፣ ያሂዱ፡-

service clickhouse-server start

አሁን ወደ ክሊክ ሃውስ ማዋቀር እንሂድ

ወደ Clickhouse ይሂዱ

clickhouse-client -h 172.26.10.109 -m

172.26.10.109 - Clickhouse የተጫነበት የአገልጋይ አይፒ.

የቬክተር ዳታቤዝ ይፍጠሩ

CREATE DATABASE vector;

የውሂብ ጎታ እንዳለ እንፈትሽ።

show databases;

ጠረጴዛውን vector.logs እንፈጥራለን.

/* Это таблица где хранятся логи как есть */

CREATE TABLE vector.logs
(
    `node_name` String,
    `timestamp` DateTime,
    `server_name` String,
    `user_id` String,
    `request_full` String,
    `request_user_agent` String,
    `request_http_host` String,
    `request_uri` String,
    `request_scheme` String,
    `request_method` String,
    `request_length` UInt64,
    `request_time` Float32,
    `request_referrer` String,
    `response_status` UInt16,
    `response_body_bytes_sent` UInt64,
    `response_content_type` String,
    `remote_addr` IPv4,
    `remote_port` UInt32,
    `remote_user` String,
    `upstream_addr` IPv4,
    `upstream_port` UInt32,
    `upstream_bytes_received` UInt64,
    `upstream_bytes_sent` UInt64,
    `upstream_cache_status` String,
    `upstream_connect_time` Float32,
    `upstream_header_time` Float32,
    `upstream_response_length` UInt64,
    `upstream_response_time` Float32,
    `upstream_status` UInt16,
    `upstream_content_type` String,
    INDEX idx_http_host request_http_host TYPE set(0) GRANULARITY 1
)
ENGINE = MergeTree()
PARTITION BY toYYYYMMDD(timestamp)
ORDER BY timestamp
TTL timestamp + toIntervalMonth(1)
SETTINGS index_granularity = 8192;

ሠንጠረዦቹ መፈጠሩን ያረጋግጡ። እንጀምራለን clickhouse-client እና ጥያቄ ያቅርቡ.

ወደ ቬክተር ዳታቤዝ እንሂድ።

use vector;

Ok.

0 rows in set. Elapsed: 0.001 sec.

ጠረጴዛዎቹን እንይ.

show tables;

┌─name────────────────┐
│ logs                │
└─────────────────────┘

ተመሳሳዩን መረጃ ወደ Elasticsearch ለመላክ elasticsearchን በ4ኛው አገልጋይ ላይ በመጫን ከ Clickhouse ጋር ለማነፃፀር

የህዝብ ሪፒኤም ቁልፍ ያክሉ

rpm --import https://artifacts.elastic.co/GPG-KEY-elasticsearch

2 ሪፖዎችን እንፍጠር፡-

/etc/yum.repos.d/elasticsearch.repo

[elasticsearch]
name=Elasticsearch repository for 7.x packages
baseurl=https://artifacts.elastic.co/packages/7.x/yum
gpgcheck=1
gpgkey=https://artifacts.elastic.co/GPG-KEY-elasticsearch
enabled=0
autorefresh=1
type=rpm-md

/etc/yum.repos.d/kibana.repo

[kibana-7.x]
name=Kibana repository for 7.x packages
baseurl=https://artifacts.elastic.co/packages/7.x/yum
gpgcheck=1
gpgkey=https://artifacts.elastic.co/GPG-KEY-elasticsearch
enabled=1
autorefresh=1
type=rpm-md

elasticsearch እና kibana ን ይጫኑ

yum install -y kibana elasticsearch

በ1 ምሳሌ ስለሚሆን ወደ /etc/elasticsearch/elasticsearch.yml ፋይል ማከል አለብህ፡-

discovery.type: single-node

ቬክተር ከሌላ አገልጋይ ወደ elasticsearch መረጃ እንዲልክ፣ network.host እንለውጣለን።

network.host: 0.0.0.0

ከኪባና ጋር ለመገናኘት በ/etc/kibana/kibana.yml ፋይል ውስጥ የአገልጋይ.host መለኪያን ይቀይሩ

server.host: "0.0.0.0"

የድሮ እና የelasticsearchን በራስ-ሰር ያካትቱ

systemctl enable elasticsearch
systemctl start elasticsearch

እና ኪባና

systemctl enable kibana
systemctl start kibana

Elasticsearchን ለነጠላ መስቀለኛ መንገድ 1 ሻርድ፣ 0 ቅጂ በማዘጋጀት ላይ። ምናልባትም ብዙ ቁጥር ያላቸው አገልጋዮች ስብስብ ሊኖርዎት ይችላል እና ይህን ማድረግ አያስፈልግዎትም።

ለወደፊት ኢንዴክሶች፣ ነባሪውን አብነት ያዘምኑ፡-

curl -X PUT http://localhost:9200/_template/default -H 'Content-Type: application/json' -d '{"index_patterns": ["*"],"order": -1,"settings": {"number_of_shards": "1","number_of_replicas": "0"}}'

ቅንብር የቬክተር በ 2 አገልጋይ ላይ ለ Logstash ምትክ

yum install -y https://packages.timber.io/vector/0.9.X/vector-x86_64.rpm mc httpd-tools screen

ለሎግስታሽ ምትክ ቬክተርን እናዋቅር። ፋይሉን ማረም /etc/vector/vector.toml

# /etc/vector/vector.toml

data_dir = "/var/lib/vector"

[sources.nginx_input_vector]
  # General
  type                          = "vector"
  address                       = "0.0.0.0:9876"
  shutdown_timeout_secs         = 30

[transforms.nginx_parse_json]
  inputs                        = [ "nginx_input_vector" ]
  type                          = "json_parser"

[transforms.nginx_parse_add_defaults]
  inputs                        = [ "nginx_parse_json" ]
  type                          = "lua"
  version                       = "2"

  hooks.process = """
  function (event, emit)

    function split_first(s, delimiter)
      result = {};
      for match in (s..delimiter):gmatch("(.-)"..delimiter) do
          table.insert(result, match);
      end
      return result[1];
    end

    function split_last(s, delimiter)
      result = {};
      for match in (s..delimiter):gmatch("(.-)"..delimiter) do
          table.insert(result, match);
      end
      return result[#result];
    end

    event.log.upstream_addr             = split_first(split_last(event.log.upstream_addr, ', '), ':')
    event.log.upstream_bytes_received   = split_last(event.log.upstream_bytes_received, ', ')
    event.log.upstream_bytes_sent       = split_last(event.log.upstream_bytes_sent, ', ')
    event.log.upstream_connect_time     = split_last(event.log.upstream_connect_time, ', ')
    event.log.upstream_header_time      = split_last(event.log.upstream_header_time, ', ')
    event.log.upstream_response_length  = split_last(event.log.upstream_response_length, ', ')
    event.log.upstream_response_time    = split_last(event.log.upstream_response_time, ', ')
    event.log.upstream_status           = split_last(event.log.upstream_status, ', ')

    if event.log.upstream_addr == "" then
        event.log.upstream_addr = "127.0.0.1"
    end

    if (event.log.upstream_bytes_received == "-" or event.log.upstream_bytes_received == "") then
        event.log.upstream_bytes_received = "0"
    end

    if (event.log.upstream_bytes_sent == "-" or event.log.upstream_bytes_sent == "") then
        event.log.upstream_bytes_sent = "0"
    end

    if event.log.upstream_cache_status == "" then
        event.log.upstream_cache_status = "DISABLED"
    end

    if (event.log.upstream_connect_time == "-" or event.log.upstream_connect_time == "") then
        event.log.upstream_connect_time = "0"
    end

    if (event.log.upstream_header_time == "-" or event.log.upstream_header_time == "") then
        event.log.upstream_header_time = "0"
    end

    if (event.log.upstream_response_length == "-" or event.log.upstream_response_length == "") then
        event.log.upstream_response_length = "0"
    end

    if (event.log.upstream_response_time == "-" or event.log.upstream_response_time == "") then
        event.log.upstream_response_time = "0"
    end

    if (event.log.upstream_status == "-" or event.log.upstream_status == "") then
        event.log.upstream_status = "0"
    end

    emit(event)

  end
  """

[transforms.nginx_parse_remove_fields]
    inputs                              = [ "nginx_parse_add_defaults" ]
    type                                = "remove_fields"
    fields                              = ["data", "file", "host", "source_type"]

[transforms.nginx_parse_coercer]

    type                                = "coercer"
    inputs                              = ["nginx_parse_remove_fields"]

    types.request_length = "int"
    types.request_time = "float"

    types.response_status = "int"
    types.response_body_bytes_sent = "int"

    types.remote_port = "int"

    types.upstream_bytes_received = "int"
    types.upstream_bytes_send = "int"
    types.upstream_connect_time = "float"
    types.upstream_header_time = "float"
    types.upstream_response_length = "int"
    types.upstream_response_time = "float"
    types.upstream_status = "int"

    types.timestamp = "timestamp"

[sinks.nginx_output_clickhouse]
    inputs   = ["nginx_parse_coercer"]
    type     = "clickhouse"

    database = "vector"
    healthcheck = true
    host = "http://172.26.10.109:8123" #  Адрес Clickhouse
    table = "logs"

    encoding.timestamp_format = "unix"

    buffer.type = "disk"
    buffer.max_size = 104900000
    buffer.when_full = "block"

    request.in_flight_limit = 20

[sinks.elasticsearch]
    type = "elasticsearch"
    inputs   = ["nginx_parse_coercer"]
    compression = "none"
    healthcheck = true
    # 172.26.10.116 - сервер где установен elasticsearch
    host = "http://172.26.10.116:9200" 
    index = "vector-%Y-%m-%d"

የtransforms.nginx_parse_add_defaults ክፍልን ማርትዕ ይችላሉ።

ጀምሮ Vyacheslav Rakhinsky እነዚህን አወቃቀሮች ለትንሽ ሲዲኤን ይጠቀማል እና እዚያ ብዙ እሴቶች ወደ ላይ ሊደርሱ ይችላሉ_*

ለምሳሌ:

"upstream_addr": "128.66.0.10:443, 128.66.0.11:443, 128.66.0.12:443"
"upstream_bytes_received": "-, -, 123"
"upstream_status": "502, 502, 200"

ይህ የእርስዎ ሁኔታ ካልሆነ ይህ ክፍል ቀላል ሊሆን ይችላል

ለsystemd /etc/systemd/system/vector.service የአገልግሎት ቅንብሮችን ይፍጠሩ

# /etc/systemd/system/vector.service

[Unit]
Description=Vector
After=network-online.target
Requires=network-online.target

[Service]
User=vector
Group=vector
ExecStart=/usr/bin/vector
ExecReload=/bin/kill -HUP $MAINPID
Restart=no
StandardOutput=syslog
StandardError=syslog
SyslogIdentifier=vector

[Install]
WantedBy=multi-user.target

ጠረጴዛዎችን ከፈጠሩ በኋላ ቬክተርን ማሄድ ይችላሉ

systemctl enable vector
systemctl start vector

የቬክተር ምዝግብ ማስታወሻዎች እንደዚህ ሊታዩ ይችላሉ

journalctl -f -u vector

መዝገቦቹ እንደዚህ ያሉ ግቤቶችን መያዝ አለባቸው

INFO vector::topology::builder: Healthcheck: Passed.
INFO vector::topology::builder: Healthcheck: Passed.

በደንበኛው (የድር አገልጋይ) - 1 ኛ አገልጋይ

በጠቅታ ሃውስ ውስጥ ያለው የምዝግብ ማስታወሻ ሠንጠረዥ መስኩን ስለሚጠቀም በ nginx ባለው አገልጋይ ላይ ipv6 ን ማሰናከል ያስፈልግዎታል። upstream_addr IPv4 ከውስጥ ipv6 ስለማልጠቀም። ipv6 ካልተሰናከለ ስህተቶች ይኖራሉ፡-

DB::Exception: Invalid IPv4 value.: (while read the value of key upstream_addr)

ምናልባት አንባቢዎች፣ ለipv6 ድጋፍ ያክሉ።

ፋይል ይፍጠሩ /etc/sysctl.d/98-disable-ipv6.conf

net.ipv6.conf.all.disable_ipv6 = 1
net.ipv6.conf.default.disable_ipv6 = 1
net.ipv6.conf.lo.disable_ipv6 = 1

ቅንብሮችን በመተግበር ላይ

sysctl --system

nginx ን ጫን።

የ nginx ማከማቻ ፋይል ታክሏል /etc/yum.repos.d/nginx.repo

[nginx-stable]
name=nginx stable repo
baseurl=http://nginx.org/packages/centos/$releasever/$basearch/
gpgcheck=1
enabled=1
gpgkey=https://nginx.org/keys/nginx_signing.key
module_hotfixes=true

የ nginx ጥቅልን ይጫኑ

yum install -y nginx

በመጀመሪያ የ Nginx ሎግ ቅርጸትን በ /etc/nginx/nginx.conf ፋይል ውስጥ ማዋቀር አለብን

user  nginx;
# you must set worker processes based on your CPU cores, nginx does not benefit from setting more than that
worker_processes auto; #some last versions calculate it automatically

# number of file descriptors used for nginx
# the limit for the maximum FDs on the server is usually set by the OS.
# if you don't set FD's then OS settings will be used which is by default 2000
worker_rlimit_nofile 100000;

error_log  /var/log/nginx/error.log warn;
pid        /var/run/nginx.pid;

# provides the configuration file context in which the directives that affect connection processing are specified.
events {
    # determines how much clients will be served per worker
    # max clients = worker_connections * worker_processes
    # max clients is also limited by the number of socket connections available on the system (~64k)
    worker_connections 4000;

    # optimized to serve many clients with each thread, essential for linux -- for testing environment
    use epoll;

    # accept as many connections as possible, may flood worker connections if set too low -- for testing environment
    multi_accept on;
}

http {
    include       /etc/nginx/mime.types;
    default_type  application/octet-stream;

    log_format  main  '$remote_addr - $remote_user [$time_local] "$request" '
                      '$status $body_bytes_sent "$http_referer" '
                      '"$http_user_agent" "$http_x_forwarded_for"';

log_format vector escape=json
    '{'
        '"node_name":"nginx-vector",'
        '"timestamp":"$time_iso8601",'
        '"server_name":"$server_name",'
        '"request_full": "$request",'
        '"request_user_agent":"$http_user_agent",'
        '"request_http_host":"$http_host",'
        '"request_uri":"$request_uri",'
        '"request_scheme": "$scheme",'
        '"request_method":"$request_method",'
        '"request_length":"$request_length",'
        '"request_time": "$request_time",'
        '"request_referrer":"$http_referer",'
        '"response_status": "$status",'
        '"response_body_bytes_sent":"$body_bytes_sent",'
        '"response_content_type":"$sent_http_content_type",'
        '"remote_addr": "$remote_addr",'
        '"remote_port": "$remote_port",'
        '"remote_user": "$remote_user",'
        '"upstream_addr": "$upstream_addr",'
        '"upstream_bytes_received": "$upstream_bytes_received",'
        '"upstream_bytes_sent": "$upstream_bytes_sent",'
        '"upstream_cache_status":"$upstream_cache_status",'
        '"upstream_connect_time":"$upstream_connect_time",'
        '"upstream_header_time":"$upstream_header_time",'
        '"upstream_response_length":"$upstream_response_length",'
        '"upstream_response_time":"$upstream_response_time",'
        '"upstream_status": "$upstream_status",'
        '"upstream_content_type":"$upstream_http_content_type"'
    '}';

    access_log  /var/log/nginx/access.log  main;
    access_log  /var/log/nginx/access.json.log vector;      # Новый лог в формате json

    sendfile        on;
    #tcp_nopush     on;

    keepalive_timeout  65;

    #gzip  on;

    include /etc/nginx/conf.d/*.conf;
}

የአሁኑን ውቅርዎን ላለማቋረጥ Nginx ብዙ የመዳረሻ_ሎግ መመሪያዎች እንዲኖርዎት ይፈቅድልዎታል።

access_log  /var/log/nginx/access.log  main;            # Стандартный лог
access_log  /var/log/nginx/access.json.log vector;      # Новый лог в формате json

ለአዳዲስ ሎግዎች (ሎግ ሎግ) ለመመዝገብ ህግ ማከልን አይርሱ (የሎግ ፋይሉ በ .log ካላለቀ)

default.conf ከ /etc/nginx/conf.d/ ሰርዝ

rm -f /etc/nginx/conf.d/default.conf

ምናባዊ አስተናጋጅ አክል /etc/nginx/conf.d/vhost1.conf

server {
    listen 80;
    server_name vhost1;
    location / {
        proxy_pass http://172.26.10.106:8080;
    }
}

ምናባዊ አስተናጋጅ አክል /etc/nginx/conf.d/vhost2.conf

server {
    listen 80;
    server_name vhost2;
    location / {
        proxy_pass http://172.26.10.108:8080;
    }
}

ምናባዊ አስተናጋጅ አክል /etc/nginx/conf.d/vhost3.conf

server {
    listen 80;
    server_name vhost3;
    location / {
        proxy_pass http://172.26.10.109:8080;
    }
}

ምናባዊ አስተናጋጅ አክል /etc/nginx/conf.d/vhost4.conf

server {
    listen 80;
    server_name vhost4;
    location / {
        proxy_pass http://172.26.10.116:8080;
    }
}

ምናባዊ አስተናጋጆችን (172.26.10.106 nginx የተጫነበት የአገልጋይ አይፒ) በ /etc/hosts ፋይል ውስጥ ላሉ ሁሉም አገልጋዮች ያክሉ።

172.26.10.106 vhost1
172.26.10.106 vhost2
172.26.10.106 vhost3
172.26.10.106 vhost4

እና ሁሉም ነገር ዝግጁ ከሆነ

nginx -t 
systemctl restart nginx

አሁን እንጫን የቬክተር

yum install -y https://packages.timber.io/vector/0.9.X/vector-x86_64.rpm

ለsystemd /etc/systemd/system/vector.service የቅንብሮች ፋይል ይፍጠሩ

[Unit]
Description=Vector
After=network-online.target
Requires=network-online.target

[Service]
User=vector
Group=vector
ExecStart=/usr/bin/vector
ExecReload=/bin/kill -HUP $MAINPID
Restart=no
StandardOutput=syslog
StandardError=syslog
SyslogIdentifier=vector

[Install]
WantedBy=multi-user.target

እና የፋይልቢት ምትክን በ /etc/vector/vector.toml config ያዋቅሩ። አይፒ አድራሻ 172.26.10.108 የምዝግብ ማስታወሻ አገልጋይ (ቬክተር-ሰርቨር) አይፒ አድራሻ ነው።

data_dir = "/var/lib/vector"

[sources.nginx_file]
  type                          = "file"
  include                       = [ "/var/log/nginx/access.json.log" ]
  start_at_beginning            = false
  fingerprinting.strategy       = "device_and_inode"

[sinks.nginx_output_vector]
  type                          = "vector"
  inputs                        = [ "nginx_file" ]

  address                       = "172.26.10.108:9876"

Не забудте добавить юзера vector в нужную группу что бы он мог читать log файлы. Например, nginx в centos создает логи с правами группы adm.

usermod -a -G adm vector

የቬክተር አገልግሎቱን እንጀምር

systemctl enable vector
systemctl start vector

የቬክተር ምዝግብ ማስታወሻዎች እንደዚህ ሊታዩ ይችላሉ

journalctl -f -u vector

ምዝግብ ማስታወሻዎች እንደዚህ ያለ ነገር ሊኖራቸው ይገባል

INFO vector::topology::builder: Healthcheck: Passed.

የጭንቀት ሙከራ

ሙከራ የሚካሄደው Apache benchmark በመጠቀም ነው።

የ httpd-tools ጥቅል በሁሉም አገልጋዮች ላይ ተጭኗል

በስክሪኑ ላይ ከ4 የተለያዩ አገልጋዮች Apache benchmark በመጠቀም መሞከር እንጀምራለን። በመጀመሪያ፣ የስክሪን ተርሚናል ብዜትሬክተሩን እናስጀምራለን፣ እና ከዚያ በApache ቤንችማርክ መሞከር እንጀምራለን። ከስክሪኑ ጋር እንዴት እንደሚሠሩ ፣ ሊያገኙት ይችላሉ። ጽሑፍ.

ከ 1 ኛ አገልጋይ

while true; do ab -H "User-Agent: 1server" -c 100 -n 10 -t 10 http://vhost1/; sleep 1; done

ከ 2 ኛ አገልጋይ

while true; do ab -H "User-Agent: 2server" -c 100 -n 10 -t 10 http://vhost2/; sleep 1; done

ከ 3 ኛ አገልጋይ

while true; do ab -H "User-Agent: 3server" -c 100 -n 10 -t 10 http://vhost3/; sleep 1; done

ከ 4 ኛ አገልጋይ

while true; do ab -H "User-Agent: 4server" -c 100 -n 10 -t 10 http://vhost4/; sleep 1; done

በ Clickhouse ውስጥ ያለውን መረጃ እንፈትሽ

ወደ Clickhouse ይሂዱ

clickhouse-client -h 172.26.10.109 -m

የSQL መጠይቅ ማድረግ

SELECT * FROM vector.logs;

┌─node_name────┬───────────timestamp─┬─server_name─┬─user_id─┬─request_full───┬─request_user_agent─┬─request_http_host─┬─request_uri─┬─request_scheme─┬─request_method─┬─request_length─┬─request_time─┬─request_referrer─┬─response_status─┬─response_body_bytes_sent─┬─response_content_type─┬───remote_addr─┬─remote_port─┬─remote_user─┬─upstream_addr─┬─upstream_port─┬─upstream_bytes_received─┬─upstream_bytes_sent─┬─upstream_cache_status─┬─upstream_connect_time─┬─upstream_header_time─┬─upstream_response_length─┬─upstream_response_time─┬─upstream_status─┬─upstream_content_type─┐
│ nginx-vector │ 2020-08-07 04:32:42 │ vhost1      │         │ GET / HTTP/1.0 │ 1server            │ vhost1            │ /           │ http           │ GET            │             66 │        0.028 │                  │             404 │                       27 │                       │ 172.26.10.106 │       45886 │             │ 172.26.10.106 │             0 │                     109 │                  97 │ DISABLED              │                     0 │                0.025 │                       27 │                  0.029 │             404 │                       │
└──────────────┴─────────────────────┴─────────────┴─────────┴────────────────┴────────────────────┴───────────────────┴─────────────┴────────────────┴────────────────┴────────────────┴──────────────┴──────────────────┴─────────────────┴──────────────────────────┴───────────────────────┴───────────────┴─────────────┴─────────────┴───────────────┴───────────────┴─────────────────────────┴─────────────────────┴───────────────────────┴───────────────────────┴──────────────────────┴──────────────────────────┴────────────────────────┴─────────────────┴───────────────────────

በ Clickhouse ውስጥ የጠረጴዛዎችን መጠን ይወቁ

select concat(database, '.', table)                         as table,
       formatReadableSize(sum(bytes))                       as size,
       sum(rows)                                            as rows,
       max(modification_time)                               as latest_modification,
       sum(bytes)                                           as bytes_size,
       any(engine)                                          as engine,
       formatReadableSize(sum(primary_key_bytes_in_memory)) as primary_keys_size
from system.parts
where active
group by database, table
order by bytes_size desc;

በ Clickhouse ውስጥ ስንት ምዝግብ ማስታወሻዎች እንደወሰዱ እንወቅ።