Title
#users-market-data
a

Andrew Bannerman

10/04/2022, 2:10 AM
I placed this in its own thread
def connectionSender():
    global sender
    sender = Sender(HOST, PORT)
    sender.connect()
Then I have a separate function which which creates the new rows from the incoming data from the broker:
def buffer_Send(bidPrice, askPrice, bidSize, askSize, year, month, day, hour, minute, second):
    try:
        buf = Buffer(init_capacity=1024, max_name_len=127)
        buf.row(
            'es_ticks',
            columns={
                'bidPrice': bidPrice,
                'askPrice': askPrice,
                'bidSize': int(bidSize),
etc... and sends the data to the database