[influxdb] Re: Kapacitor and external InfluxDB.
вторник, 11 октября 2016 г., 20:29:26 UTC+3 пользователь codep...@gmail.com написал: > I'm having a hard time setting up a record. Currently kapacitor.conf contains: > > [[influxdb]] > enabled = true > name = "cp" > default = true > urls = ["http://influx-cp.internal:8086;] > username = "root" > password = "root" > ssl-ca = "" > ssl-cert = "" > ssl-key = "" > insecure-skip-verify = false > timeout = "0" > disable-subscriptions = false > subscription-protocol = "http" > kapacitor-hostname = "" > http-port = 0 > udp-bind = "" > udp-buffer = 1000 > udp-read-buffer = 0 > startup-timeout = "5m0s" > subscriptions-sync-interval = "1m0s" > [influxdb.subscriptions] > [influxdb.excluded-subscriptions] > _kapacitor = ["autogen"] > > I'm launching it using this: > > kapacitord -config kapacitor.conf > > And trying to record it using this: > > kapacitor record stream -task cpu_alert -duration 20s > > With basic script: > > stream > // Select just the cpu measurement from our example database. > |from() > .database('cp') > |alert() > // Whenever we get an alert write it to a file. > .log('/tmp/alerts.log') > > As expected - record hangs forever. What I'm trying to find out - is > kapacitor receiving any data at all? How to find out, and how to fix? > > The log during record is this: > [run] 2016/10/11 20:28:08 I! Kapacitor starting, version 1.0.2, branch > master, commit 1011dba109bf3d83366c87873ec285c7f9140d34 > [run] 2016/10/11 20:28:08 I! Go version go1.6.3 > [srv] 2016/10/11 20:28:08 I! Kapacitor hostname: cp > [srv] 2016/10/11 20:28:08 I! ClusterID: 8106cac2-bb07-4f1b-8b36-5f55fead461b > ServerID: 2eace6cb-8fb7-485c-9055-41bba6bc06cc > [task_master:main] 2016/10/11 20:28:08 I! opened > [task_store] 2016/10/11 20:28:08 W! could not open old boltd for task_store. > Not performing migration. Remove the `task_store.dir` configuration to > disable migration. > [stats] 2016/10/11 20:28:08 I! opened service > [httpd] 2016/10/11 20:28:08 I! Starting HTTP service > [httpd] 2016/10/11 20:28:08 I! Authentication enabled: false > [httpd] 2016/10/11 20:28:08 I! Listening on HTTP: [::]:9092 > [run] 2016/10/11 20:28:08 I! Listening for signals > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:26 +0300] "POST > /kapacitor/v1/recordings/stream HTTP/1.1" 201 213 "-" "KapacitorClient" > 1e169f2d-8fd8-11e6-8001- 14495 > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:26 +0300] "GET > /kapacitor/v1/recordings/24fdaef0-71a2-418e-85dc-5ce7d37f4399 HTTP/1.1" 202 > 213 "-" "KapacitorClient" 1e656681-8fd8-11e6-8002- 1308 > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:27 +0300] "GET > /kapacitor/v1/recordings/24fdaef0-71a2-418e-85dc-5ce7d37f4399 HTTP/1.1" 202 > 213 "-" "KapacitorClient" 1eb21dfd-8fd8-11e6-8003- 1270 > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:27 +0300] "GET > /kapacitor/v1/recordings/24fdaef0-71a2-418e-85dc-5ce7d37f4399 HTTP/1.1" 202 > 213 "-" "KapacitorClient" 1efecdcf-8fd8-11e6-8004- 4212 > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:28 +0300] "GET > /kapacitor/v1/recordings/24fdaef0-71a2-418e-85dc-5ce7d37f4399 HTTP/1.1" 202 > 213 "-" "KapacitorClient" 1f4bfd80-8fd8-11e6-8005- 1458 > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:28 +0300] "GET > /kapacitor/v1/recordings/24fdaef0-71a2-418e-85dc-5ce7d37f4399 HTTP/1.1" 202 > 213 "-" "KapacitorClient" 1f98b84d-8fd8-11e6-8006- 3302 > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:29 +0300] "GET > /kapacitor/v1/recordings/24fdaef0-71a2-418e-85dc-5ce7d37f4399 HTTP/1.1" 202 > 213 "-" "KapacitorClient" 1fe5c68e-8fd8-11e6-8007- 992 > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:29 +0300] "GET > /kapacitor/v1/recordings/24fdaef0-71a2-418e-85dc-5ce7d37f4399 HTTP/1.1" 202 > 213 "-" "KapacitorClient" 2032666d-8fd8-11e6-8008- 3905 > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:30 +0300] "GET > /kapacitor/v1/recordings/24fdaef0-71a2-418e-85dc-5ce7d37f4399 HTTP/1.1" 202 > 213 "-" "KapacitorClient" 207f7cda-8fd8-11e6-8009- 1025 > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:30 +0300] "GET > /kapacitor/v1/recordings/24fdaef0-71a2-418e-85dc-5ce7d37f4399 HTTP/1.1" 202 > 213 "-" "KapacitorClient" 20cc2039-8fd8-11e6-800a- 3076 > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:31 +0300] "GET > /kapacitor/v1/recordings/24fdaef0-71a2-418e-85dc-5ce7d37f4399 HTTP/1.1" 202 > 213 "-" "KapacitorClient" 21192566-8fd8-11e6-800b- 971 > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:31 +0300] "GET > /kapacitor/v1/recordings/24fdaef0-71a2-418e-85dc-5ce7d37f4399 HTTP/1.1" 202 > 213 "-" "KapacitorClient" 2165bc53-8fd8-11e6-800c- 592 > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:32 +0300] "GET > /kapacitor/v1/recordings/24fdaef0-71a2-418e-85dc-5ce7d37f4399 HTTP/1.1" 202 > 213 "-" "KapacitorClient" 21b24533-8fd8-11e6-800d- 4535 > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:32 +0300] "GET >
[influxdb] Re: Kapacitor and external InfluxDB.
What is the output of `kapacitor show task_name` for your task? On Wednesday, October 12, 2016 at 9:49:44 AM UTC-6, codep...@gmail.com wrote: > > And kapacitor list recordings produces: > ID TypeStatusSize Date > > f6dc1d97-6bba-4beb-9ba5-29e52c10cd4bstream finished 23 B 12 Oct > 16 18:48 MSK > c442a78a-9267-448e-a21a-5073895b2f42stream finished 23 B 12 Oct > 16 18:37 MSK > 336fef32-e386-4b33-8b6f-338e47482176stream finished 23 B 12 Oct > 16 18:33 MSK > b18d463a-7aff-491f-8fee-308cc5ea8b11stream finished 23 B 12 Oct > 16 18:32 MSK > b7e933e9-41dd-41ac-bfb4-082bb3fa4f29stream finished 23 B 12 Oct > 16 15:37 MSK -- Remember to include the version number! --- You received this message because you are subscribed to the Google Groups "InfluxData" group. To unsubscribe from this group and stop receiving emails from it, send an email to influxdb+unsubscr...@googlegroups.com. To post to this group, send email to influxdb@googlegroups.com. Visit this group at https://groups.google.com/group/influxdb. To view this discussion on the web visit https://groups.google.com/d/msgid/influxdb/b90c06c8-3b07-4506-a076-a591e0b3cc46%40googlegroups.com. For more options, visit https://groups.google.com/d/optout.
[influxdb] Re: Kapacitor and external InfluxDB.
Hmm - now it no longer freezes, but doesn't record anything either. Current script is: stream // Select just the cpu measurement from our example database. |from() .database('cp') .measurement('user_cp') |alert() // Whenever we get an alert write it to a file. .info(lambda: "value" > 500.0) .log('/tmp/alerts.log') :~$ kapacitor stats ingress Database Retention Policy Measurement Points Received cpdefault fm_cp 2426 _internal monitor tsm1_cache 35092 _kapacitorautogen kapacitor 1132 _internal monitor udp 1132 cpdefault user_cp 1710771 _kapacitorautogen ingress 21504 _kapacitorautogen edges 2266 _internal monitor subscriber 6792 _internal monitor database 5660 _internal monitor httpd 1132 _internal monitor shard 35092 _internal monitor tsm1_filestore 35092 _internal monitor queryExecutor 1132 _kapacitorautogen runtime 1132 _internal monitor cq 1132 _internal monitor write 1132 _internal monitor tsm1_wal 35092 _internal monitor tsm1_engine 35092 _internal monitor runtime 1132 and SHOW SUBSCRIPTIONS produces: { "results": [{ "series": [{ "name": "cp", "columns": ["retention_policy", "name", "mode", "destinations"], "values": [ ["default", "kapacitor-6ad61546-9c23-4936-83b8-cce438e2de91", "ANY", ["http://vvm-dev35.internal:9092;]] ] }, { "name": "_internal", "columns": ["retention_policy", "name", "mode", "destinations"], "values": [ ["monitor", "kapacitor-6ad61546-9c23-4936-83b8-cce438e2de91", "ANY", ["http://vm-dev35.internal:9092;]] ] }, { "name": "cp-test", "columns": ["retention_policy", "name", "mode", "destinations"], "values": [ ["default", "kapacitor-6ad61546-9c23-4936-83b8-cce438e2de91", "ANY", ["http://vm-dev35.internal:9092;]] ] }, { "name": "cp-tst", "columns": ["retention_policy", "name", "mode", "destinations"], "values": [ ["default", "kapacitor-6ad61546-9c23-4936-83b8-cce438e2de91", "ANY", ["http://vm-dev35.internal:9092;]] ] }, { "name": "everest4", "columns": ["retention_policy", "name", "mode", "destinations"], "values": [ ["autogen", "kapacitor-6ad61546-9c23-4936-83b8-cce438e2de91", "ANY", ["http://vm-dev35.internal:9092;]] ] }] }] } > Kapacitor isn't receiving any data from InfluxDB. What is the output of > > > show subscriptions > > > and > > > kapacitor stats ingress > > > > > On Tuesday, October 11, 2016 at 11:29:26 AM UTC-6, codep...@gmail.com > wrote:I'm having a hard time setting up a record. Currently kapacitor.conf > contains: > [[influxdb]] > enabled = true > name = "cp" > default = true > urls = ["http://influx-cp.internal:8086;] > username = "root" > password = "root" > ssl-ca = "" > ssl-cert = "" > ssl-key = "" > insecure-skip-verify = false > timeout = "0" > disable-subscriptions = false > subscription-protocol = "http" > kapacitor-hostname = "" > http-port = 0 > udp-bind = "" > udp-buffer = 1000 > udp-read-buffer = 0 > startup-timeout = "5m0s" > subscriptions-sync-interval = "1m0s" > [influxdb.subscriptions] >
[influxdb] Re: Kapacitor and external InfluxDB.
вторник, 11 октября 2016 г., 21:07:28 UTC+3 пользователь nath...@influxdb.com написал: > Kapacitor isn't receiving any data from InfluxDB. What is the output of > > > show subscriptions > > > and > > > kapacitor stats ingress > > > > > On Tuesday, October 11, 2016 at 11:29:26 AM UTC-6, codep...@gmail.com > wrote:I'm having a hard time setting up a record. Currently kapacitor.conf > contains: > [[influxdb]] > enabled = true > name = "cp" > default = true > urls = ["http://influx-cp.internal:8086;] > username = "root" > password = "root" > ssl-ca = "" > ssl-cert = "" > ssl-key = "" > insecure-skip-verify = false > timeout = "0" > disable-subscriptions = false > subscription-protocol = "http" > kapacitor-hostname = "" > http-port = 0 > udp-bind = "" > udp-buffer = 1000 > udp-read-buffer = 0 > startup-timeout = "5m0s" > subscriptions-sync-interval = "1m0s" > [influxdb.subscriptions] > [influxdb.excluded-subscriptions] > _kapacitor = ["autogen"] > I'm launching it using this: > kapacitord -config kapacitor.conf > And trying to record it using this: > kapacitor record stream -task cpu_alert -duration 20s > With basic script: > stream > // Select just the cpu measurement from our example database. > |from() > .database('cp') > |alert() > // Whenever we get an alert write it to a file. > .log('/tmp/alerts.log') > As expected - record hangs forever. What I'm trying to find out - is > kapacitor receiving any data at all? How to find out, and how to fix? > The log during record is this: > [run] 2016/10/11 20:28:08 I! Kapacitor starting, version 1.0.2, branch > master, commit 1011dba109bf3d83366c87873ec285c7f9140d34 > [run] 2016/10/11 20:28:08 I! Go version go1.6.3 > [srv] 2016/10/11 20:28:08 I! Kapacitor hostname: cp > [srv] 2016/10/11 20:28:08 I! ClusterID: 8106cac2-bb07-4f1b-8b36-5f55fead461b > ServerID: 2eace6cb-8fb7-485c-9055-41bba6bc06cc > [task_master:main] 2016/10/11 20:28:08 I! opened > [task_store] 2016/10/11 20:28:08 W! could not open old boltd for task_store. > Not performing migration. Remove the `task_store.dir` configuration to > disable migration. > [stats] 2016/10/11 20:28:08 I! opened service > [httpd] 2016/10/11 20:28:08 I! Starting HTTP service > [httpd] 2016/10/11 20:28:08 I! Authentication enabled: false > [httpd] 2016/10/11 20:28:08 I! Listening on HTTP: [::]:9092 > [run] 2016/10/11 20:28:08 I! Listening for signals > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:26 +0300] "POST > /kapacitor/v1/recordings/stream HTTP/1.1" 201 213 "-" "KapacitorClient" > 1e169f2d-8fd8-11e6-8001- 14495 > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:26 +0300] "GET > /kapacitor/v1/recordings/24fdaef0-71a2-418e-85dc-5ce7d37f4399 HTTP/1.1" 202 > 213 "-" "KapacitorClient" 1e656681-8fd8-11e6-8002- 1308 > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:27 +0300] "GET > /kapacitor/v1/recordings/24fdaef0-71a2-418e-85dc-5ce7d37f4399 HTTP/1.1" 202 > 213 "-" "KapacitorClient" 1eb21dfd-8fd8-11e6-8003- 1270 > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:27 +0300] "GET > /kapacitor/v1/recordings/24fdaef0-71a2-418e-85dc-5ce7d37f4399 HTTP/1.1" 202 > 213 "-" "KapacitorClient" 1efecdcf-8fd8-11e6-8004- 4212 > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:28 +0300] "GET > /kapacitor/v1/recordings/24fdaef0-71a2-418e-85dc-5ce7d37f4399 HTTP/1.1" 202 > 213 "-" "KapacitorClient" 1f4bfd80-8fd8-11e6-8005- 1458 > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:28 +0300] "GET > /kapacitor/v1/recordings/24fdaef0-71a2-418e-85dc-5ce7d37f4399 HTTP/1.1" 202 > 213 "-" "KapacitorClient" 1f98b84d-8fd8-11e6-8006- 3302 > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:29 +0300] "GET > /kapacitor/v1/recordings/24fdaef0-71a2-418e-85dc-5ce7d37f4399 HTTP/1.1" 202 > 213 "-" "KapacitorClient" 1fe5c68e-8fd8-11e6-8007- 992 > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:29 +0300] "GET > /kapacitor/v1/recordings/24fdaef0-71a2-418e-85dc-5ce7d37f4399 HTTP/1.1" 202 > 213 "-" "KapacitorClient" 2032666d-8fd8-11e6-8008- 3905 > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:30 +0300] "GET > /kapacitor/v1/recordings/24fdaef0-71a2-418e-85dc-5ce7d37f4399 HTTP/1.1" 202 > 213 "-" "KapacitorClient" 207f7cda-8fd8-11e6-8009- 1025 > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:30 +0300] "GET > /kapacitor/v1/recordings/24fdaef0-71a2-418e-85dc-5ce7d37f4399 HTTP/1.1" 202 > 213 "-" "KapacitorClient" 20cc2039-8fd8-11e6-800a- 3076 > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:31 +0300] "GET > /kapacitor/v1/recordings/24fdaef0-71a2-418e-85dc-5ce7d37f4399 HTTP/1.1" 202 > 213 "-" "KapacitorClient" 21192566-8fd8-11e6-800b- 971 > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:31 +0300] "GET > /kapacitor/v1/recordings/24fdaef0-71a2-418e-85dc-5ce7d37f4399 HTTP/1.1" 202 > 213 "-" "KapacitorClient" 2165bc53-8fd8-11e6-800c- 592 > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:32 +0300] "GET
[influxdb] Re: Kapacitor and external InfluxDB.
Kapacitor isn't receiving any data from InfluxDB. What is the output of show subscriptions and kapacitor stats ingress On Tuesday, October 11, 2016 at 11:29:26 AM UTC-6, codep...@gmail.com wrote: > > I'm having a hard time setting up a record. Currently kapacitor.conf > contains: > > [[influxdb]] > enabled = true > name = "cp" > default = true > urls = ["http://influx-cp.internal:8086;] > username = "root" > password = "root" > ssl-ca = "" > ssl-cert = "" > ssl-key = "" > insecure-skip-verify = false > timeout = "0" > disable-subscriptions = false > subscription-protocol = "http" > kapacitor-hostname = "" > http-port = 0 > udp-bind = "" > udp-buffer = 1000 > udp-read-buffer = 0 > startup-timeout = "5m0s" > subscriptions-sync-interval = "1m0s" > [influxdb.subscriptions] > [influxdb.excluded-subscriptions] > _kapacitor = ["autogen"] > > I'm launching it using this: > > kapacitord -config kapacitor.conf > > And trying to record it using this: > > kapacitor record stream -task cpu_alert -duration 20s > > With basic script: > > stream > // Select just the cpu measurement from our example database. > |from() > .database('cp') > |alert() > // Whenever we get an alert write it to a file. > .log('/tmp/alerts.log') > > As expected - record hangs forever. What I'm trying to find out - is > kapacitor receiving any data at all? How to find out, and how to fix? > > The log during record is this: > [run] 2016/10/11 20:28:08 I! Kapacitor starting, version 1.0.2, branch > master, commit 1011dba109bf3d83366c87873ec285c7f9140d34 > [run] 2016/10/11 20:28:08 I! Go version go1.6.3 > [srv] 2016/10/11 20:28:08 I! Kapacitor hostname: cp > [srv] 2016/10/11 20:28:08 I! ClusterID: > 8106cac2-bb07-4f1b-8b36-5f55fead461b ServerID: > 2eace6cb-8fb7-485c-9055-41bba6bc06cc > [task_master:main] 2016/10/11 20:28:08 I! opened > [task_store] 2016/10/11 20:28:08 W! could not open old boltd for > task_store. Not performing migration. Remove the `task_store.dir` > configuration to disable migration. > [stats] 2016/10/11 20:28:08 I! opened service > [httpd] 2016/10/11 20:28:08 I! Starting HTTP service > [httpd] 2016/10/11 20:28:08 I! Authentication enabled: false > [httpd] 2016/10/11 20:28:08 I! Listening on HTTP: [::]:9092 > [run] 2016/10/11 20:28:08 I! Listening for signals > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:26 +0300] "POST > /kapacitor/v1/recordings/stream HTTP/1.1" 201 213 "-" "KapacitorClient" > 1e169f2d-8fd8-11e6-8001- 14495 > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:26 +0300] "GET > /kapacitor/v1/recordings/24fdaef0-71a2-418e-85dc-5ce7d37f4399 HTTP/1.1" 202 > 213 "-" "KapacitorClient" 1e656681-8fd8-11e6-8002- 1308 > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:27 +0300] "GET > /kapacitor/v1/recordings/24fdaef0-71a2-418e-85dc-5ce7d37f4399 HTTP/1.1" 202 > 213 "-" "KapacitorClient" 1eb21dfd-8fd8-11e6-8003- 1270 > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:27 +0300] "GET > /kapacitor/v1/recordings/24fdaef0-71a2-418e-85dc-5ce7d37f4399 HTTP/1.1" 202 > 213 "-" "KapacitorClient" 1efecdcf-8fd8-11e6-8004- 4212 > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:28 +0300] "GET > /kapacitor/v1/recordings/24fdaef0-71a2-418e-85dc-5ce7d37f4399 HTTP/1.1" 202 > 213 "-" "KapacitorClient" 1f4bfd80-8fd8-11e6-8005- 1458 > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:28 +0300] "GET > /kapacitor/v1/recordings/24fdaef0-71a2-418e-85dc-5ce7d37f4399 HTTP/1.1" 202 > 213 "-" "KapacitorClient" 1f98b84d-8fd8-11e6-8006- 3302 > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:29 +0300] "GET > /kapacitor/v1/recordings/24fdaef0-71a2-418e-85dc-5ce7d37f4399 HTTP/1.1" 202 > 213 "-" "KapacitorClient" 1fe5c68e-8fd8-11e6-8007- 992 > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:29 +0300] "GET > /kapacitor/v1/recordings/24fdaef0-71a2-418e-85dc-5ce7d37f4399 HTTP/1.1" 202 > 213 "-" "KapacitorClient" 2032666d-8fd8-11e6-8008- 3905 > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:30 +0300] "GET > /kapacitor/v1/recordings/24fdaef0-71a2-418e-85dc-5ce7d37f4399 HTTP/1.1" 202 > 213 "-" "KapacitorClient" 207f7cda-8fd8-11e6-8009- 1025 > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:30 +0300] "GET > /kapacitor/v1/recordings/24fdaef0-71a2-418e-85dc-5ce7d37f4399 HTTP/1.1" 202 > 213 "-" "KapacitorClient" 20cc2039-8fd8-11e6-800a- 3076 > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:31 +0300] "GET > /kapacitor/v1/recordings/24fdaef0-71a2-418e-85dc-5ce7d37f4399 HTTP/1.1" 202 > 213 "-" "KapacitorClient" 21192566-8fd8-11e6-800b- 971 > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:31 +0300] "GET > /kapacitor/v1/recordings/24fdaef0-71a2-418e-85dc-5ce7d37f4399 HTTP/1.1" 202 > 213 "-" "KapacitorClient" 2165bc53-8fd8-11e6-800c- 592 > [httpd] 127.0.0.1 - - [11/Oct/2016:20:28:32 +0300] "GET > /kapacitor/v1/recordings/24fdaef0-71a2-418e-85dc-5ce7d37f4399 HTTP/1.1" 202 > 213 "-"