mirror of
https://github.com/rsyslog/rsyslog.git
synced 2025-12-15 12:50:41 +01:00
399444841d
Input source for clickhouse tests was changed to injectmsg where it is possible. This will result in a shorter and easier to read debug file and the tests won't fail duo to port problems on the testbench.
40 lines
1.5 KiB
Bash
Executable File
40 lines
1.5 KiB
Bash
Executable File
#!/bin/bash
|
|
# add 2018-12-07 by Pascal Withopf, released under ASL 2.0
|
|
. ${srcdir:=.}/diag.sh init
|
|
export NUMMESSAGES=10
|
|
generate_conf
|
|
add_conf '
|
|
module(load="../plugins/omclickhouse/.libs/omclickhouse")
|
|
|
|
template(name="outfmt" option.stdsql="on" type="string" string="INSERT INTO rsyslog.bulk (id, severity, facility, timestamp, ipaddress, tag, message) VALUES (%msg:F,58:2%, %syslogseverity%, %syslogfacility%, '
|
|
add_conf "'%timereported:::date-unixtimestamp%', '%fromhost-ip%', '%syslogtag%', '%msg%')"
|
|
add_conf '")
|
|
|
|
|
|
:syslogtag, contains, "tag" action(type="omclickhouse" server="localhost" port="8443"
|
|
user="default" pwd="" template="outfmt")
|
|
'
|
|
|
|
clickhouse-client --query="CREATE TABLE IF NOT EXISTS rsyslog.bulk ( id Int32, severity Int8, facility Int8, timestamp DateTime, ipaddress String, tag String, message String ) ENGINE = MergeTree() PARTITION BY severity Order By id"
|
|
|
|
startup
|
|
injectmsg
|
|
shutdown_when_empty
|
|
wait_shutdown
|
|
clickhouse-client --query="SELECT id, severity, facility, ipaddress, tag, message FROM rsyslog.bulk ORDER BY id" > $RSYSLOG_OUT_LOG
|
|
|
|
export EXPECTED='0 7 20 127.0.0.1 tag msgnum:00000000:
|
|
1 7 20 127.0.0.1 tag msgnum:00000001:
|
|
2 7 20 127.0.0.1 tag msgnum:00000002:
|
|
3 7 20 127.0.0.1 tag msgnum:00000003:
|
|
4 7 20 127.0.0.1 tag msgnum:00000004:
|
|
5 7 20 127.0.0.1 tag msgnum:00000005:
|
|
6 7 20 127.0.0.1 tag msgnum:00000006:
|
|
7 7 20 127.0.0.1 tag msgnum:00000007:
|
|
8 7 20 127.0.0.1 tag msgnum:00000008:
|
|
9 7 20 127.0.0.1 tag msgnum:00000009:'
|
|
cmp_exact $RSYSLOG_OUT_LOG
|
|
|
|
clickhouse-client --query="DROP TABLE rsyslog.bulk"
|
|
exit_test
|