def _init_subscribe(self):
    contract_col = self._db.get_collection('realtime_future_contract_info')
    code = contract_col.find()
    self.prod_codes = {c['Filler']: c['CODE'] for c in code}
    for p in self.prod_codes:
        self.subscribe_ticker(p)
    for p in self.prod_codes:
        self.subscribe_price(p)
def _init_subscribe(self):
    contract_col = self._db.get_collection('realtime_future_contract_info')
    code = contract_col.find()
    self.prod_codes = {c['Filler']: c['CODE'] for c in code}
    for p in self.prod_codes:
        self.subscribe_ticker(p)
    for p in self.prod_codes:
        self.subscribe_price(p)