diff --git a/pkg/rule_engine/nodes/action_save_timeseries_node.go b/pkg/rule_engine/nodes/action_save_timeseries_node.go index 10a387c..2b6fcd7 100644 --- a/pkg/rule_engine/nodes/action_save_timeseries_node.go +++ b/pkg/rule_engine/nodes/action_save_timeseries_node.go @@ -2,7 +2,6 @@ package nodes import ( "github.com/sirupsen/logrus" - "log" "pandax/pkg/global" "pandax/pkg/rule_engine/message" ) @@ -36,10 +35,7 @@ func (n *saveTimeSeriesNode) Handle(msg *message.Message) error { } //deviceId := msg.GetMetadata().GetValues()["deviceId"].(string) deviceName := msg.Metadata["deviceName"].(string) - log.Println(msg.Msg) - log.Println(msg.Metadata) err := global.TdDb.InsertDevice(deviceName+"_telemetry", msg.Msg) - log.Println(err) if err != nil { if failureLabelNode != nil { return failureLabelNode.Handle(msg) diff --git a/pkg/rule_engine/nodes/filter_message_type_switch_node.go b/pkg/rule_engine/nodes/filter_message_type_switch_node.go index 0797117..032f592 100644 --- a/pkg/rule_engine/nodes/filter_message_type_switch_node.go +++ b/pkg/rule_engine/nodes/filter_message_type_switch_node.go @@ -34,7 +34,6 @@ func (f messageTypeSwitchNodeFactory) Create(id string, meta Metadata) (Node, er func (n *messageTypeSwitchNode) Handle(msg *message.Message) error { logrus.Infof("%s handle message '%s'", n.Name(), msg.MsgType) - msg.Metadata = map[string]interface{}{"AA": "BB", "deviceName": "fff"} nodes := n.GetLinkedNodes() messageType := msg.MsgType for label, node := range nodes { diff --git a/shutdown.bat b/shutdown.bat index ace1693..51543dd 100644 --- a/shutdown.bat +++ b/shutdown.bat @@ -1 +1 @@ -taskkill /pid 32872 -t -f \ No newline at end of file +taskkill /pid 20548 -t -f \ No newline at end of file