Как лучше всего загрузить файл ILP в QuestDB? Расширенный ⇐ Python

[Anonymous]

1 год и 7 месяцев назад был вопрос с таким же названием, и этот вопрос закрыт.
Я использовал скрипт из ответа

Код: Выделить всё

import socket
import sys

sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

def send_utf8(msg):
print(msg)
sock.sendall(msg.encode())

if __name__ == '__main__':
try:
sock.connect(('localhost', 9009))
with open("YOUR_FILE") as infile:
for line in infile:
# print(line)
send_utf8(line)
except socket.error as e:
sys.stderr.write(f'Got error: {e}')
sock.close()

все работает, но через несколько секунд появилась ошибка:
Получена ошибка: [Errno 32] Разрыв трубы
Я пытался замедлить работу скрипта с помощью сна (0.01), поэтому я получил немного больше данных в questDB, но через несколько минут снова появляется ошибка.
И я также попробовал что-то с «сигналом» Я обнаружил переполнение стека, но не могу заставить его работать для всего моего файла размером 18 ГБ.
Может кто-нибудь помочь мне расширить скрипт для непрерывной работы.

Подробнее здесь: https://stackoverflow.com/questions/789 ... b-extended