"""Simple debugging nodes"""
import csv
import pandas as pd
from timeflux.core.node import Node
[docs]class Display(Node):
"""Display input."""
def __init__(self, meta=False, data=True):
self._meta = meta
self._data = data
[docs] def update(self):
if self.i.ready() and self._data:
self.logger.debug("\n %s" % self.i.data)
if self.i.meta and self._meta:
self.logger.debug("\n %s" % self.i.meta)
[docs]class Dump(Node):
"""Dump to CSV."""
def __init__(self, fname="/tmp/dump.csv"):
self.writer = csv.writer(open(fname, "a"))
[docs] def update(self):
if self.i.ready():
self.i.data["index"] = self.i.data.index.values.astype("float64") / 1e9
self.writer.writerows(self.i.data.values.tolist())