In [11]:

    

import MessageFormatting
import importlib
importlib.reload(MessageFormatting)
from MessageFormatting import *


    

In [12]:

    

from timeseries.ArrayTimeSeries import ArrayTimeSeries as ts
import numpy as np
from scipy.stats import norm

t = np.arange(0.0, 1.0, 0.01)
v = norm.pdf(t, 100, 100) + 1000*np.random.randn(100)
ts_test = ts(t, v)

#d2 = {'op':'TSfromID','id':12,'courtesy':'please'}
d2 = {'op':'simsearch_id','id':12,'n_closest':2,'courtesy':'please'}
#d2 = {'op':'simsearch_ts','ts':[list(ts_test.times()), list(ts_test.values())],'courtesy':'please'}
s2 = serialize(json.dumps(d2))


    

In [13]:

    

import sys
from socket import socket, AF_INET, SOCK_STREAM
s = socket(AF_INET, SOCK_STREAM)
s.connect(('localhost', 20000))
s.send(s2)
msg = s.recv(8192)
print(msg)


    

    




b',\x00\x00\x00{"op": "simsearch_id", "id": [821, 203]}'

In [ ]:

    

ds = Deserializer()
ds.append(msg)
ds.ready()
response = ds.deserialize()
#print(response)
if 'ts' in response:
    a = response['ts']
elif 'id' in response:
    a = response['id']
print(response)
print(a)


    

In [1]:

    

import TimeseriesDB