| | |
|---|
| | | |
|---|
| | | |
|---|
| | | def __upload_codes_info(datas): |
|---|
| | | if not tool.is_trade_time(): |
|---|
| | | return |
|---|
| | | data_bytes = socket_util.load_header(json.dumps({"type": "l1_data", "data": datas})) |
|---|
| | | # if not tool.is_trade_time(): |
|---|
| | | # return |
|---|
| | | data_bytes = socket_util.load_header(json.dumps({"type": "l1_data", "data": datas}).encode("utf-8")) |
|---|
| | | # 上传数据 |
|---|
| | | sk = socket_util.create_socket(SERVER_HOST, SERVER_PORT) |
|---|
| | | try: |
|---|
| | |
|---|
| | | |
|---|
| | | def test_add_datas(): |
|---|
| | | while True: |
|---|
| | | print("发送测试数据") |
|---|
| | | level1_data_queue.put_nowait(("000948", 12.91, 14.20, int(34.60 * 10000), 4.9 * 1e8, tool.get_now_time_str())) |
|---|
| | | time.sleep(3) |
|---|
| | | |
|---|
| | |
|---|
| | | # "000969", 9.46, 9.11, 771000*100, time.time()) |
|---|
| | | # level1_data_dict["002292"] = ( |
|---|
| | | # "002292", 8.06, 9.96, 969500 * 100, time.time()) |
|---|
| | | # TODO:测试 |
|---|
| | | threading.Thread(target= lambda: test_add_datas(), daemon=True).start() |
|---|
| | | # 测试 |
|---|
| | | # threading.Thread(target= lambda: test_add_datas(), daemon=True).start() |
|---|
| | | # 等待程序结束 |
|---|
| | | while True: |
|---|
| | | try: |
|---|
