关于ip寻优和热更新 about pytdx HOT 11 CLOSED

# coding: utf-8

# In[ ]:

import QUANTAXIS as QA


# In[ ]:

import threading
import queue


# In[ ]:

ip_job=queue.Queue()
ip_task=QA.QA_Queue(ip_job)


# In[ ]:

ip_task.setName('ip_task')


# In[ ]:

ip_task.start()


# In[ ]:

from pytdx.hq import TdxHq_API


# In[ ]:

api=TdxHq_API()


# In[ ]:

#for i in range(5):
   # ip_job.put({'fn':print(QA.QAUtil.QA_util_web_ping('www.baidu.com'))})


# In[ ]:

ip_list = [
        '119.147.212.81:7709',
        '221.231.141.60:7709',
        '101.227.73.20:7709',
        '101.227.77.254:7709',
        '14.215.128.18:7709'
        '59.173.18.140:7709',
        '58.23.131.163:7709',
        '218.6.170.47:7709',
        '123.125.108.14:7709',
        '60.28.23.80:7709',
        '218.60.29.136:7709',
        '218.85.139.19:7709',
        '218.85.139.20:7709',
        '122.192.35.44:7709',
        '122.192.35.44:7709'
    ]


# In[ ]:

ip_addr=[]
for item in ip_list:
    ip_addr.append(item.split(':')[0])


# In[ ]:

ip_addr


# In[ ]:

def select_best(url_list):
    ms_list=[]
    for item in url_list:
        ms_list.append(QA.QAUtil.QA_util_web_ping(item))
    return url_list[ms_list.index(min(ms_list))]

ip_job.put({'fn':print(select_best(ip_addr))})


# In[ ]:

ip_job.put({'fn':print(select_best(ip_addr))})

import threading

timer=threading.Timer(600,ip_job.put({'fn':send_to_redis/ssdb(select_best(ip_addr))})
#这样就变成10分钟,定期往任务队列里面发一个更新最优ip的任务

import QUANTAXIS as QA
import queue
task_job=queue.Queue()
task_=QA.QA_Queue(task_job)
task_.setName('task_sche')
task_.start()
def ten_min_job():
    timer=threading.Timer(600,ip_job.put({'fn':send_to_redis/ssdb(select_best(ip_addr))})
    time.sleep(600)
    
    ten_min_job()
task_job.put({'fn':ten_min_job()})