In [6]:
import logging
logger = logging.getLogger()
logger.setLevel(logging.DEBUG)
logging.debug("Logger active")
In [7]:
from pyvast import VAST
import pyarrow
In [8]:
vast = VAST()
In [9]:
await vast.test_connection()
Out[9]:
In [12]:
stdout, stderr = await vast.export().arrow("#type == \"zeek.conn\"").exec()
reader = pyarrow.ipc.open_stream(stdout)
data = reader.read_all()
In [13]:
data.shape
Out[13]:
In [14]:
import pandas
df = data.to_pandas()
In [15]:
df.describe()
Out[15]:
In [ ]: