in jupyter/demo.py [0:0]
def init_book(self):
db = tbapi.TickDb.createFromUrl(self.tb_url)
try:
db.open(True)
stream = db.getStream(self.stream_key)
options = tbapi.SelectionOptions()
try:
cursor = db.select(current_milli_time() - 10000, [stream], options,
[self.record_type],
[self.symbol])
while cursor.next():
msg = cursor.getMessage()
if msg.packageType == 'PERIODICAL_SNAPSHOT':
self.process_snapshot(msg.entries)
break
finally:
cursor.close()
finally:
db.close()