import featurestream as fs
fs.set_access('your_access_key')
# do a quick health check on the service
print 'healthy=',fs.check_health()

import featurestream.csv as csv
events = csv.csv_iterator('../resources/KDDTrain_1Percent.csv')

e = events.next()
e

stream = fs.start_stream(targets={'41':'CATEGORIC','40':'NUMERIC'})

stream

stream.stream_id

t=stream.train_iterator(events, batch=500)

t

stream.predict(e)

stream.predict_full(e)

stream.predict_full({})

stream.related_fields('41')

stream.get_stats()['41']

stream.get_stats()['40']

stream.get_stats()['41']['accuracy']

fs.get_streams()

stream.close()