2016-10-27 6 views
6

私はtickscript開発中に、処理ノードを通過した後にストリーム状態をダンプする機会があるかどうか疑問に思っています(ファイルstdoutへのログ)?kapacitorのチックスクリプトを開発する際にデバッグ情報を取得する方法は?

+0

あなたは何をあなたに説明することができます」もう少し探しています。私はあなたが何を求めているか完全にわからない –

+1

ログノードがありますが、データをInfluxDbに書き戻すことを好む。この目的のために、データが蓄積されないように1日間の保存ポリシーを設定した別の流入データベースがあります。 –

+0

Kapacitor [REST API経由の統計情報](https://docs.influxdata.com/kapacitor/v1.1/api/api/#tasks)を取得し、InfluxDBに読み込むことができます。私はInfluxDataがこのためにTelegrafプラグインをリリースするかどうか疑問に思います - 自然な進歩のようです。 – rbinnun

答えて

1

kapacitor show TASK_NAMEコマンドを実行すると、あなたのデータポイントは、どのノードに到達したどのように多くに関する統計情報が含まれていgraph descriptionがありますタスク自体に関するけどDOT:セクションの下にいくつかの情報を表示する必要があります。

デバッグのもう1つの方法は、InfluxDBOutNodeを使用してポイントを保存し、何が処理されているかを確認することです。お役に立てれば。

0

KapacitorにはLog Nodeがあり、ストリーム状態をKapacitorログファイルにダンプできます。

使用の際には、それは次のようになります。

stream.from()... 
    |window() 
     .period(10s) 
     .every(10s) 
    |log() 
    |count('value') 
3

が、私はそれが有用な目的をデバッグするため|httpOut('id')を入れました。後でhttp://kapacitor-host:9092/kapacitor/v1/tasks/<task_id>/<httpOut_id>にアクセスし、そのノードを通過しているデータを確認することができます。

0

私は別のデータベースにダニスクリプト内からデータをダンプすることができるよ...

stream 
    |from() 
     .database('telegraf') 
     .measurement('cpu') 
     .groupBy(*) 
     .where(lambda: "cpu" == 'cpu-total') 
    |eval(lambda: 100.0 - "usage_idle") 
     .as('usage_util') 
     .keep() 
     .quiet() 
    |InfluxDBOut() 
     .create() 
     .database('debugging') 

その後、私は結果を表示するためにChronografエクスプローラを使用して...

関連する問題