小果网页---套利系统添加了可以套利模块，提供数据api

最近在小果套利系统里面添加了一下可以套利模块，同时实现了盘中自动更新，30分钟更新一次。给大家提交交易参考，可以套利模块的选择

df=df[df['申购状态'] !='暂停申购']df=df[df['申购限额'] !='无限额']df['溢价率']=df['溢价率'].astype(float)df['成交量']=df['成交量'].astype(float)df=df[df['溢价率']>=1.2]df=df[df['成交量']>=1000000]

成交量大于100万，溢价率对于1.2，申购状态不是暂停申购，申购限额不是无限额

网页http://120.78.132.143:8023/

图片

点击lof套利模块 网页http://120.78.132.143:8023/lof_fund_data_analysis_app

点击运行，在点击不运行在点运行

图片

可以点击排序溢价率

图片

可以点击下载数据下载数据

图片

下载的数据

图片

全部的lof数据

图片

套利分析

图片

可以套利模块

图片

历史溢价率

图片

可以选择状态的标的

图片

历史数据

图片

交易状态查询可以选择标的

图片

源代码全部上传了知识星球可以下载

图片

可以加我备注加群，进入我的量化研究群

图片

数据api​​​​​

import pandas as pdimport jsonimport requestsimport osclass xg_financial_database:    '''    小果金融数据库    '''    def __init__(self,url='http://120.78.132.143',port=8023,password='123456'):        '''        小果金融数据库        url服务器网页        port端口        password授权码        '''        self.url=url        self.port=port        self.password=password        self.path=os.path.dirname(os.path.abspath(__file__))    def get_user_info(self):        '''        获取用户信息        '''        url='{}:{}/_dash-update-component'.format(self.url,self.port)        headers={'Content-Type':'application/json'}        data={            "output":"finace_data_table_1.data@c28c1f466316fd80f79b58b2e7baab2f",            "outputs":{"id":"finace_data_table_1","property":"data@c28c1f466316fd80f79b58b2e7baab2f"},            "inputs":[{"id":"finace_data_password","property":"value","value":"{}".format(self.password)},            {"id":"finace_data_data_type","property":"value","value":"代码"},            {"id":"finace_data_text","property":"value","value":"from trader_tool.stock_data import stock_data\nstock_data=stock_data()\ndf=stock_data.get_stock_hist_data_em(stock='600031',start_date='20210101',end_date='20600101',data_type='D',count=8000)\ndf.to_csv(r'{}\\数据\\{}数据.csv')\n                \n                "},            {"id":"finace_data_run","property":"value","value":"运行"},            {"id":"finace_data_down_data","property":"value","value":"不下载数据"}],            "changedPropIds":["finace_data_run.value"]}        res=requests.post(url=url,data=json.dumps(data),headers=headers)        text=res.json()        df=pd.DataFrame(text['response']['finace_data_table_1']['data'])        return df    def get_user_def_data(self,func=''):        '''        自定义数据获取        调用数据库        '''        text=self.params_func(text=func)        func=text        info=self.get_user_info()        print(info)        url='{}:{}/_dash-update-component'.format(self.url,self.port)        headers={'Content-Type':'application/json'}        data={"output":"finace_data_table.data@c28c1f466316fd80f79b58b2e7baab2f",            "outputs":{"id":"finace_data_table","property":"data@c28c1f466316fd80f79b58b2e7baab2f"},            "inputs":[{"id":"finace_data_password","property":"value","value":"{}".format(self.password)},            {"id":"finace_data_data_type","property":"value","value":"代码"},            {"id":"finace_data_text","property":"value","value":"{}".format(func)},            {"id":"finace_data_run","property":"value","value":"运行"},            {"id":"finace_data_down_data","property":"value","value":"不下载数据"}],            "changedPropIds":["finace_data_run.value"]}        res=requests.post(url=url,data=json.dumps(data),headers=headers)        text=res.json()        df=pd.DataFrame(text['response']['finace_data_table']['data'])        return info, df    def params_func(self,text=''):        '''        解析函数        '''        data_list=[]        f=text.split('\n')        for i in f:            text=i.strip().lstrip()            data_list.append(text)        func='\n'.join(data_list)        return func    def get_all_etf_data(self):        '''        获取全部的etf数据        '''        func="""        from trader_tool.dfcf_etf_data import dfcf_etf_data        data=dfcf_etf_data()        df=data.get_all_etf_data()        df.to_csv(r'{}\数据\{}数据.csv')        """        info,df=self.get_user_def_data(func=func)        return info,df    def get_bond_etf_data(self):        '''        获取债券的etf数据        '''        func="""        from trader_tool.dfcf_etf_data import dfcf_etf_data        data=dfcf_etf_data()        df=data.get_bond_etf_data()        df.to_csv(r'{}\数据\{}数据.csv')        """        info,df=self.get_user_def_data(func=func)        return info,df    def get_sz_sh_etf(self):        '''        获取A股ETF数据        '''        func="""        from trader_tool.dfcf_etf_data import dfcf_etf_data        data=dfcf_etf_data()        df=data.get_sz_sh_etf()        df.to_csv(r'{}\数据\{}数据.csv')        """        info,df=self.get_user_def_data(func=func)        return info,df    def get_wp_etf_data(self):        '''        获取外盘ETF数据        '''        func="""        from trader_tool.dfcf_etf_data import dfcf_etf_data        data=dfcf_etf_data()        df=data.get_wp_etf_data()        df.to_csv(r'{}\数据\{}数据.csv')        """        info,df=self.get_user_def_data(func=func)        return info,df    def get_sp_etf_data(self):        '''        获取商品ETF数据        '''        func="""        from trader_tool.dfcf_etf_data import dfcf_etf_data        data=dfcf_etf_data()        df=data.get_sp_etf_data()        df.to_csv(r'{}\数据\{}数据.csv')        """        info,df=self.get_user_def_data(func=func)        return info,df    def get_hot_spot_investment(self):        '''        获取ETF热点投资数据        '''        func="""        from trader_tool.dfcf_etf_data import dfcf_etf_data        data=dfcf_etf_data()        df=data.get_hot_spot_investment()        df.to_csv(r'{}\数据\{}数据.csv')        """        info,df=self.get_user_def_data(func=func)        return info,df    def get_hot_spot_investment(self):        '''        获取ETF热点投资数据        '''        func="""        from trader_tool.dfcf_etf_data import dfcf_etf_data        data=dfcf_etf_data()        df=data.get_hot_spot_investment()        df.to_csv(r'{}\数据\{}数据.csv')        """        info,df=self.get_user_def_data(func=func)        return info,df    def get_limit_up_pool(self,date='20240126'):        '''        获取涨停板数据        '''        func="""        from trader_tool.ths_limitup_data import ths_limitup_data        data=ths_limitup_data()        df=data.read_func_data(func="self.get_limit_up_pool(date={})")        print(df)        """.format(date)+"""        df.to_csv(r'{}\数据\{}数据.csv')        """        info,df=self.get_user_def_data(func=func)        return info,df    def get_limit_up(self,date=''):        '''        冲刺涨停        '''        func="""        from trader_tool.ths_limitup_data import ths_limitup_data        data=ths_limitup_data()        df=data.read_func_data(func="self.get_limit_up(date={})")        print(df)        """.format(date)+"""        df.to_csv(r'{}\数据\{}数据.csv')        """        info,df=self.get_user_def_data(func=func)        return info,df    def get_continuous_limit_pool(self,date='20230925'):        '''        连扳        '''        func="""        from trader_tool.ths_limitup_data import ths_limitup_data        data=ths_limitup_data()        df=data.read_func_data(func="self.get_continuous_limit_pool(date={})")        print(df)        """.format(date)+"""        df.to_csv(r'{}\数据\{}数据.csv')        """        info,df=self.get_user_def_data(func=func)        return info,df    def get_open_limit_pool(self,date='20230925'):        '''        炸板池        '''        func="""        from trader_tool.ths_limitup_data import ths_limitup_data        data=ths_limitup_data()        df=data.read_func_data(func="self.get_open_limit_pool(date={})")        print(df)        """.format(date)+"""        df.to_csv(r'{}\数据\{}数据.csv')        """        info,df=self.get_user_def_data(func=func)        return info,df    def get_lower_limit_pool(self,date='20230101'):        '''        跌停        '''        func="""        from trader_tool.ths_limitup_data import ths_limitup_data        data=ths_limitup_data()        df=data.read_func_data(func="self.get_lower_limit_pool(date={})")        print(df)        """.format(date)+"""        df.to_csv(r'{}\数据\{}数据.csv')        """        info,df=self.get_user_def_data(func=func)        return info,df    def get_block_top_pool(self,date='20230101'):        '''        最强风口        '''        func="""        from trader_tool.ths_limitup_data import ths_limitup_data        data=ths_limitup_data()        df=data.read_func_data(func="self.get_block_top_pool(date={})")        print(df)        """.format(date)+"""        df.to_csv(r'{}\数据\{}数据.csv')        """        info,df=self.get_user_def_data(func=func)        return info,df    def get_analysis_block_top_pool(self,date='20240101'):        '''        解析最强风口        '''        func="""        from trader_tool.ths_limitup_data import ths_limitup_data        data=ths_limitup_data()        df=data.read_func_data(func="self.get_analysis_block_top_pool(date={})")        print(df)        """.format(date)+"""        df.to_csv(r'{}\数据\{}数据.csv')        """        info,df=self.get_user_def_data(func=func)        return info,df    def get_stock_continuous_limit_up(self,date='20240101'):        '''        连扳天梯        '''        func="""        from trader_tool.ths_limitup_data import ths_limitup_data        data=ths_limitup_data()        df=data.read_func_data(func="self.get_stock_continuous_limit_up(date={})")        print(df)        """.format(date)+"""        df.to_csv(r'{}\数据\{}数据.csv')        """        info,df=self.get_user_def_data(func=func)        return info,df    def get_hot_stock_rank(self):        func="""        from trader_tool.ths_rq import ths_rq        models=ths_rq()        df=models.get_hot_stock_rank()        print(df)        df.to_csv(r'{}\数据\{}数据.csv')        """        info,df=self.get_user_def_data(func=func)        return info,df    def get_stock_concept_rot_rank(self):        func="""        from trader_tool.ths_rq import ths_rq        models=ths_rq()        df=models.get_stock_concept_rot_rank()        print(df)        df.to_csv(r'{}\数据\{}数据.csv')        """        info,df=self.get_user_def_data(func=func)        return info,df    def get_stock_industry_rot_rank(self):        func="""        from trader_tool.ths_rq import ths_rq        models=ths_rq()        df=models.get_stock_industry_rot_rank()        print(df)        df.to_csv(r'{}\数据\{}数据.csv')        """        info,df=self.get_user_def_data(func=func)        return info,df    def get_etf_hot_rank(self):        func="""        from trader_tool.ths_rq import ths_rq        models=ths_rq()        df=models.get_etf_hot_rank()        print(df)        df.to_csv(r'{}\数据\{}数据.csv')        """        info,df=self.get_user_def_data(func=func)        return info,df    def get_cov_bond_rot_rank(self):        func="""        from trader_tool.ths_rq import ths_rq        models=ths_rq()        df=models.get_cov_bond_rot_rank()        print(df)        df.to_csv(r'{}\数据\{}数据.csv')        """        info,df=self.get_user_def_data(func=func)        return info,df    def get_HK_stock_rot_rank(self):        func="""        from trader_tool.ths_rq import ths_rq        models=ths_rq()        df=models.get_HK_stock_rot_rank()        print(df)        df.to_csv(r'{}\数据\{}数据.csv')        """        info,df=self.get_user_def_data(func=func)        return info,df    def get_US_stock_rot_rank(self):        func="""        from trader_tool.ths_rq import ths_rq        models=ths_rq()        df=models.get_US_stock_rot_rank()        print(df)        df.to_csv(r'{}\数据\{}数据.csv')        """        info,df=self.get_user_def_data(func=func)        return info,df    def get_futurn_hot_rank(self):        func="""        from trader_tool.ths_rq import ths_rq        models=ths_rq()        df=models.get_futurn_hot_rank()        print(df)        df.to_csv(r'{}\数据\{}数据.csv')        """        info,df=self.get_user_def_data(func=func)        return info,df    def fund_lof_spot_em(self):        '''        LOF 实时行情        '''        func="""        from trader_tool.lof_fund_data import lof_fund_data        models=lof_fund_data()        df=models.fund_lof_spot_em()        print(df)        df.to_csv(r'{}\数据\{}数据.csv')        """        info,df=self.get_user_def_data(func=func)        return info,df    def fund_lof_hist_em(self,        symbol: str = "166009",        period: str = "daily",        start_date: str = "19700101",        end_date: str = "20500101",        adjust: str = "",):        '''        获取lof历史数据        '''        func="""        from trader_tool.lof_fund_data import lof_fund_data        models=lof_fund_data()        df=models.fund_lof_hist_em(symbol='{}',        period='{}',        start_date='{}',        end_date='{}',        adjust='{}')        print(df)        """.format(symbol,period,start_date,end_date,adjust)+"""        df.to_csv(r'{}\数据\{}数据.csv')        """        info,df=self.get_user_def_data(func=func)        return info,df    def fund_lof_hist_min_em(self,        symbol: str = "166009",        start_date: str = "1979-09-01 09:32:00",        end_date: str = "2222-01-01 09:32:00",        period: str = "5",        adjust: str = ""):        '''        lof分时行情        '''        func="""        from trader_tool.lof_fund_data import lof_fund_data        models=lof_fund_data()        df=models.fund_lof_hist_min_em(symbol='{}',        period='{}',        start_date='{}',        end_date='{}',        adjust='{}')        print(df)        """.format(symbol,period,start_date,end_date,adjust)+"""        df.to_csv(r'{}\数据\{}数据.csv')        """        info,df=self.get_user_def_data(func=func)        return info,df    def get_lof_fund_info_data(self,stock='501225'):        '''        获取ETF基本信息        '''        func="""        from trader_tool.lof_fund_data import lof_fund_data        models=lof_fund_data()        df=models.get_lof_fund_info_data(stock='{}')        """.format(stock)+"""        df.to_csv(r'{}\数据\{}数据.csv')        """        info,df=self.get_user_def_data(func=func)        return info,df    def get_all_lof_fund_info_data(self):        '''        获取全部lof基金数据        '''        func="""        from trader_tool.lof_fund_data import lof_fund_data        models=lof_fund_data()        df=models.get_all_lof_fund_info_data()        print(df)        df.to_csv(r'{}\数据\{}数据.csv')        """        info,df=self.get_user_def_data(func=func)        return info,dfif __name__=='__main__':    data=xg_financial_database(password='123456')    df=data.get_lof_fund_info_data(stock='501025')    print(df)

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/bicheng/12555.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Nginx的正向代理与反向代理

Nginx的正向代理与反向代理

你好呀，我是赵兴晨，文科程序员。 今天，我们将一起了解什么是Nginx的正向代理？什么是Nginx的反向代理？并实际动手实践。 以下内容都是满满的干货，绝对不容错过。我建议先收藏这篇文章，然后找一…
阅读更多...
项目管理-案例重点知识(整合管理)

项目管理-案例重点知识(整合管理)

项目管理：每天进步一点点~ 活到老，学到老 ヾ(◍∇◍)ﾉﾞ 何时学习都不晚，加油 一、整合管理 案例重点 重点内容： （1）项目章程内容和作用 （2）项目管理计划…
阅读更多...
linux系统介绍和安装教程（含安装链接放在最下面了）

linux系统介绍和安装教程（含安装链接放在最下面了）

一、linux系统简介 在Linux和C语言的发展历程中，有几位关键人物为它们的诞生和推广做出了重要贡献。 首先，肯汤姆森（Ken Thompson）是一位在AT&T公司工作的员工，他不仅发明了B语言，还创造了Unix系统。…
阅读更多...
python怎么读取xml

python怎么读取xml

引入XML组件&#xff1a;import xml.dom.minidom。 创建一个xml文件&#xff0c;<?xml version"1.0" encoding"utf-8"?>。 加载读取XML文件&#xff0c;xml.dom.minidom.parse(abc.xml)&#xff0c;这是xml文件的对象。 获取XML文档对象&#xff0…
阅读更多...
RT-DETR改进教程|加入SCNet中的SCConv[CVPR2020]自校准卷积模块！

RT-DETR改进教程|加入SCNet中的SCConv[CVPR2020]自校准卷积模块！

⭐⭐ RT-DETR改进专栏|包含主干、模块、注意力机制、检测头等前沿创新 ⭐⭐ 一、 论文介绍 论文链接&#xff1a;http://mftp.mmcheng.net/Papers/20cvprSCNet.pdf 代码链接&#xff1a;https://gitcode.com/MCG-NKU/SCNet/ 文章摘要&#xff1a; CNN的最新进展主要致力于设计更…
阅读更多...
微信小程序 - - - - - custom-tab-bar使用自定义tabbar

微信小程序 - - - - - custom-tab-bar使用自定义tabbar

custom-tab-bar使用自定义tabbar 1. 创建custom-tab-bar组件2. 修改app.json3. tabbar对应页面调整 1. 创建custom-tab-bar组件 各个文件代码如下 /custom-tab-bar/data.js export default [{text: 流水笺,iconPath: /assets/icon/bill.png,selectedIconPath: /assets/icon/bi…
阅读更多...
前端 performance api使用 —— mark、measure计算vue3页面echarts渲染时间

前端 performance api使用 —— mark、measure计算vue3页面echarts渲染时间

文章目录 ⭐前言&#x1f496;vue3系列文章 ⭐Performance api计算持续时间&#x1f496; mark用法&#x1f496; measure用法 ⭐计算echarts渲染的持续时间⭐结束 ⭐前言 大家好&#xff0c;我是yma16&#xff0c;本文分享关于 前端 performance api使用 —— mark、measure计…
阅读更多...
Java网络编程之TCP协议核心机制(一)

Java网络编程之TCP协议核心机制(一)

目录 题外话 正题 TCP协议核心机制 1.确认应答机制 2.超时重传 3.连接管理 三次握手(建立数据连接)和四次挥手(断开连接) 三次握手 三次握手的意义 为什么不能是四次挥手和两次挥手呢??? 四次挥手(断开连接) 四次挥手的意义 四次挥手能变为三次挥手吗? 小结 题…
阅读更多...
string功能介绍（普及版）

string功能介绍（普及版）

目录 1。初始化&#xff08;好几种方式&#xff09;&#xff0c;npos和string的使用说明 2。string的拷贝&#xff0c;隐式类型转换&#xff0c;[]&#xff0c;size&#xff0c;iterator&#xff0c;begin&#xff0c;end&#xff0c;reverse&#xff0c;reverse_iterator&am…
阅读更多...
基于springboot实现的家具销售电商平台

基于springboot实现的家具销售电商平台

开发语言&#xff1a;Java 框架&#xff1a;springboot JDK版本&#xff1a;JDK1.8 服务器&#xff1a;tomcat7 数据库&#xff1a;mysql 5.7&#xff08;一定要5.7版本&#xff09; 数据库工具&#xff1a;Navicat11 开发软件&#xff1a;eclipse/myeclipse/idea Maven包&…
阅读更多...
DELL服务器配置ILO(idrac)地址、修改管理员密码

DELL服务器配置ILO(idrac)地址、修改管理员密码

服务器型号&#xff1a;DELL PowerEdge R630 1、重启服务器选择F2进入BIOS 2、重启服务器选择F2进入BIOS 3、选择“Network” 4、配置iDRAC的IP&#xff0c;掩码网关&#xff0c;DNS等信息 5、Esc返回&#xff0c;下滑选择“User Configuration” 6、配置iDRAC的用户名密码以及…
阅读更多...
Spring Boot集成Ldap快速入门Demo

Spring Boot集成Ldap快速入门Demo

1.Ldap介绍 LDAP&#xff0c;Lightweight Directory Access Protocol&#xff0c;轻量级目录访问协议. LDAP是一种特殊的服务器&#xff0c;可以存储数据数据的存储是目录形式的&#xff0c;或者可以理解为树状结构&#xff08;一层套一层&#xff09;一般存储关于用户、用户…
阅读更多...
WD—C++课前作业—30题

WD—C++课前作业—30题

怎么会手和脚都在桌子上 目录 31&#xff0c;声明一个类 String,其数据成员为 char head[100],构造函数 String(char*Head)实现 head 的初始化&#xff0c;成员函数 void reverse()实现 head 内字符串的逆序存放&#xff0c;成员函数 void print()实现 head 内字符串的输出。…
阅读更多...
01基础篇

01基础篇

1、初识 JVM 1.1 什么是 JVM JVM 全称是 Java Virtual Machine&#xff0c;中文译名 Java虚拟机。JVM 本质上是一个运行在计算机上的程序&#xff0c;他的职责是运行Java字节码文件。 Java源代码执行流程如下&#xff1a; 分为三个步骤&#xff1a; 编写Java源代码文件。使用…
阅读更多...
Python轻量级Web框架Flask（14）—— 自己做Flask项目总结

Python轻量级Web框架Flask（14）—— 自己做Flask项目总结

0、前言&#xff1a; 本文意在记录自己在做毕业Flask项目开发时遇到的一些问题&#xff0c;并将问题解决方案记录下来&#xff0c;可做日后查询本文也会记录自己做FLask项目时实现的一些功能&#xff0c;作为开发工作的进程记录注意&#xff1a;用Flask开发的前提是已经设计好…
阅读更多...
Java | Leetcode Java题解之第89题格雷编码

Java | Leetcode Java题解之第89题格雷编码

题目&#xff1a; 题解&#xff1a; class Solution {public List<Integer> grayCode(int n) {List<Integer> ret new ArrayList<Integer>();for (int i 0; i < 1 << n; i) {ret.add((i >> 1) ^ i);}return ret;} }
阅读更多...
mongodb备份还原指南

mongodb备份还原指南

MongoDB 提供的命令行实用程序mongodump和mongorestore创建备份和恢复数据的过程。 一、数据备份 mongorestore和mongodump实用程序可处理BSON数据转储&#xff0c;对于创建小型部署的备份非常有用。要实现弹性且无中断的备份&#xff0c;请将文件系统快照或区块级磁盘快照与…
阅读更多...
串联所有单词的子串 ---- 滑动窗口

串联所有单词的子串 ---- 滑动窗口

题目链接 题目: 分析: 我们上次做的题目, 是找到所有字符的异位词, 和这道题有些类似, 使用记录有效字符的个数找到子字符, 此题无非是把字符变成了字符串题目回顾 有一下几方面不同, 我们以示例1为例: 1. 哈希表 上次我们使用的是哈希数组, 因为数组的下标可以是字符, 现…
阅读更多...
常类API（Math,System,Runtime)

常类API（Math,System,Runtime)

1、Math 是帮助我们用于进行数学计算的工具类私有化构造方法&#xff0c;所有的方法都是静态的 方法名 说明public static int abs(int a) 获取参数绝对值 public static double ceil(int a)向上取整public static double floor(int a)向下取…
阅读更多...
java项目之教学辅助平台(springboot+vue+mysql)

java项目之教学辅助平台(springboot+vue+mysql)

风定落花生&#xff0c;歌声逐流水&#xff0c;大家好我是风歌&#xff0c;混迹在java圈的辛苦码农。今天要和大家聊的是一款基于springboot的教学辅助平台。项目源码以及部署相关请联系风歌&#xff0c;文末附上联系信息 。 项目简介&#xff1a; 教学辅助平台的主要使用者分…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023