StartConnMktTryd.py

import socket
import win32api
import TypeDataTryd as tdt
from MarketData.OutputMarketData import OutputMarketData

#---ESCOLHER O ATIVO EXEMPLO:-----------#
# PETR4  - Petrobras
# VALE3  - Vale
# ITUB4  - Itau
# INDQ19 - Indice Bovespa
# WINQ19 - Mini Indice Bovespa
#========================================#
ATIVO = ['PETR4','VALE3','ITUB4','BBAS3','CIEL3']
#ATIVO = ['DOLU19']
#========================================#

#---INFORMACOES DO SERVIDOR--------------#
#========================================#
HOST = '127.0.0.1'
PORT = 12002
#========================================#


def ByteConvert(dataInfo, ativo):
    return str.encode(dataInfo + ativo + '#')

#Inicia a Execução
oMkt = OutputMarketData()
try:
    with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
        s.connect((HOST, PORT))
        print("Id da thread principal %d" % (win32api.GetCurrentThreadId()))
        while True:
            arrInfo = []
            try:
                for item in ATIVO:
                    s.sendall(ByteConvert(tdt.COTACAO,item) )
                    data = s.recv(32768)
                    #Acumulando os ativos
                    arrInfo.append(data.decode().replace("COT!","").split("|"))
                oMkt.OutputData(arrInfo, ATIVO)	
            except Exception as ex:
                print(ex)
            
except Exception as ex:
    print('Não foi possivel conectar no servidor RTD. Erro: ', ex)