如何用Python监控股票异动

import json


import requests
import re
from models.nettick import NetTick




class NetEaseData:
    @staticmethod
    def get_realtime_data(symbol):
        """
        网易的实时数据接口
        :param symbol: 股票代码
        :return: Tick
        """
        code = NetEaseData.convert_market(symbol)
        try:
            response = requests.get("http://api.money.126.net/data/feed/{},money.api".format(code)).text
            re_find = NetEaseData.__re_find(response)
            if re_find is not None:
                find_stock = re_find.get(code)
                if find_stock is not None:
                    return NetTick(find_stock)


        except Exception as e:
            print('请求网易接口出错，错误信息：{}'.format(e))


        return None


    @staticmethod
    def convert_market(other_market_code=str):
        """
        转换通用股票代码 sz sh bj开头+股票代码
        """
        if other_market_code[0:2].lower() == 'sh':
            return '0' + other_market_code[2:]
        elif other_market_code[0:2].lower() == 'sz':
            return '1' + other_market_code[2:]
        else:
            return '2' + other_market_code[2:]


    @staticmethod
    def get_realtime_datas(symbols=[]):
        """
        网易的实时数据接口
        :param symbols: 股票代码列表
        :return: Ticks列表
        """
        codes = [NetEaseData.convert_market(code) for code in symbols]
        result = []
        try:
            response = requests.get("http://api.money.126.net/data/feed/{},money.api".format(','.join(codes))).text
            re_find = NetEaseData.__re_find(response)
            if re_find is not None:
                for code in re_find:
                    item = re_find[code]
                    result.append(NetTick(item))
        except Exception as e:
            print('请求网易接口出错，错误信息：{}'.format(e))


        return result


    @staticmethod
    def __re_find(response):
        find = re.findall(r"_ntes_quote_callback\((.*)\);", response)
        if len(find) >= 1:
            return json.loads(find[-1])
        return None




if __name__ == '__main__':
    ticks = NetEaseData.get_realtime_datas(
        ['sz002665', 'sz002761', 'sh512710', 'sz000625', 'sh513130', 'sh512170', 'sz159995',
         'sz002425', 'sz002051', 'sz000665', 'sz000560', 'sh600166', 'sh600715', 'sh603363'])
    # up_shares = []
    # down_shares = []
    for tick in ticks:
        if tick.percent > 0:
            print(f"{tick.name}【{tick.symbol}】", tick.price,
                  "<font color='red'>%.2f" % (tick.percent * 100) + "%</font>",
                  f"最低价：{tick.low},最高价：{tick.high}", f"成交量：{tick.volume  1000000}万")
        else:
            print(f"{tick.name}【{tick.symbol}】", tick.price,
                  "<font color='info'>%.2f" % (tick.percent * 100) + "%</font>",
                  f"最低价：{tick.low},最高价：{tick.high}", f"成交量：{tick.volume  1000000}万")

class NetTick:
    def __init__(self, dict={}):
        self.name = dict.get('name')                # 股票名称
        self.yestclose = dict.get('yestclose')      # 昨日收盘价
        self.bidvol5 = dict.get('bidvol5')          # 买5数量
        self.bidvol4 = dict.get('bidvol4')          # 买4数量
        self.bidvol3 = dict.get('bidvol3')          # 买3数量
        self.bidvol2 = dict.get('bidvol2')          # 买2数量
        self.bidvol1 = dict.get('bidvol1')          # 买1数量
        self.bid5 = dict.get('bid5')                # 买5价格
        self.bid4 = dict.get('bid4')                # 买4价格
        self.bid3 = dict.get('bid3')                # 买3价格
        self.bid2 = dict.get('bid2')                # 买2价格
        self.bid1 = dict.get('bid1')                # 买1价格
        self.askvol5 = dict.get('askvol5')          # 卖5数量
        self.askvol4 = dict.get('askvol4')          # 卖4数量
        self.askvol3 = dict.get('askvol3')          # 卖3数量
        self.askvol2 = dict.get('askvol2')          # 卖2数量
        self.askvol1 = dict.get('askvol1')          # 卖1数量
        self.ask5 = dict.get('ask5')                # 卖5价格
        self.ask4 = dict.get('ask4')                # 卖4价格
        self.ask3 = dict.get('ask3')                # 卖3价格
        self.ask2 = dict.get('ask2')                # 卖2价格
        self.ask1 = dict.get('ask1')                # 卖1价格
        self.symbol = dict.get('symbol')            # 股票代码 第一位1：深交所 0：上交所 2北交所
        self.volume = dict.get('volume')            # 成交量
        self.price = dict.get('price')              # 当前价格
        self.open = dict.get('open')                # 开盘价
        self.low = dict.get('low')                  # 最低价
        self.high = dict.get('high')                # 最高价
        self.code = dict.get('code')                # 去除标记为的股票代码
        self.turnover = dict.get('turnover')        # 成交额
        self.percent = dict.get('percent')          # 涨跌幅
        self.updown = dict.get('updown')            # 涨跌金额

{
   "msgtype": "markdown",
   "markdown": {
            "content": "任务【{{.TaskName}}】执行{{.Status}},\n结果:{{.Result}}"
    }
}