交易所App开发功能交易所系统开发源码demo
交易所App开发功能｜交易所系统开发源码（demo）
区块链是一种技术。简单、通俗来说，区块链技术就是人人记账，或者分布式账本。在互联网时代，每个系统背后都有数据库，这个数据库可以看作是一个大的账本，以往都是维护系统的人负责管理数据库，记录用户的行为，也就是记账，而区块链“去中心化”，它让系统中的每一个成员都参与其中，不仅人人记账，而且通过链接，人人都能拥有完整的账本
系统开发对接唯：wwqqyy420
行情数据简介
行情数据是交易过程中基本、重要的部分。一次完整的交易通常分为三个步骤：接收行情、分析行情（策略部分）、发出买卖指令并成交（算法交易部分）。对于高频交易和低延迟交易者，行情数据的精度和细度尤其重要。精度是指数据的准确性和能在多大程度上反映市场的真实情况，细度是指行情的推送频率。
行情数据分为两部分：交易行情和订单委托行情。交易行情就是交易数据，包括新成交价、成交量、成交额、高价、低价等字段信息；订单委托行情就是买卖报价和委托量，根据委托价格的不同，可以分为一档、五档、十档等行情；通常把交易行情和订单委托行情结合在一起，形成TAQ（Trades and Quotes）行情。
tick行情也称逐笔行情，是完整记录了市场所有信息的数据，即会记录市场每一个event，如发生一次交易或者增加一个新订单，是精细和完整的行情数据。
快照（snapshot）行情是对tick行情数据在时间维度上进行一定频率切片后的统计数据，是一个时间截面上的统计数据。tick数据更为，快照行情根据时间频率的不同度也不同。
实现mysql存储
import pymysql as mysql
import pandas as pd
from sqlalchemy import create_engine
from repoistory.base.repoistory import Repoistory
import conf***nfig as conf
class MysqlRepoistory(Repoistory):
def getMysqlConn(self):
return ***nnect(
host=con***nfig.host,
port=con***nfig.port,
user=con***nfig.user,
password=con***nfig.password,
database=con***nfig.database,
charset=con***nfig.charset
)
def createMysqlEngine(self):
return create_engine(con***nfig.mysql_engine)
def handle_cursor(self,func,args,*kwargs):
connect=self.getMysqlConn()
try:
cursor_obj=connect.cursor()
func(connect,cursor_obj,args,*kwargs)
cursor_obj.close()
finally:
connect.close()
def saveData(self,data:pd.DataFrame,repoistoryParam:dict):
eng=self.createMysqlEngine()
tableName=repoistoryParam.get('table_name')
data.to_sql(name=tableName,con=eng,if_exists="append",index=False)
def readData(self,repoistoryParam:dict)->pd.DataFrame:
eng=self.createMysqlEngine()
query_sql=repoistoryParam.get('query_sql')
#index_col=repoistoryParam.get('index_col')
return pd.read_sql(sql=query_sql,con=eng)
if __name__=='__main__':
mysql=MysqlRepoistory()
repoistoryParam={"query_sql":"select*from trade_daily where stock_code='000002'"}
db=mysql.readData(repoistoryParam)
print(db)
2.使用mysql存储实例，将来换别的存储方式只需新的存储对象，然后替换掉
代码如下（示例）：
if __name__=='__main__':
mysql=MysqlRepoistory()
repoistoryParam={"query_sql":"select*from trade_daily where stock_code='000002'"}
db=mysql.readData(repoistoryParam)
print(db)
区块链是一种技术。简单、通俗来说，区块链技术就是人人记账，或者分布式账本。在互联网时代，每个系统背后都有数据库，这个数据库可以看作是一个大的账本，以往都是维护系统的人负责管理数据库，记录用户的行为，也就是记账，而区块链“去中心化”，它让系统中的每一个成员都参与其中，不仅人人记账，而且通过链接，人人都能拥有完整的账本
系统开发对接唯：wwqqyy420
行情数据简介
行情数据是交易过程中基本、重要的部分。一次完整的交易通常分为三个步骤：接收行情、分析行情（策略部分）、发出买卖指令并成交（算法交易部分）。对于高频交易和低延迟交易者，行情数据的精度和细度尤其重要。精度是指数据的准确性和能在多大程度上反映市场的真实情况，细度是指行情的推送频率。
行情数据分为两部分：交易行情和订单委托行情。交易行情就是交易数据，包括新成交价、成交量、成交额、高价、低价等字段信息；订单委托行情就是买卖报价和委托量，根据委托价格的不同，可以分为一档、五档、十档等行情；通常把交易行情和订单委托行情结合在一起，形成TAQ（Trades and Quotes）行情。
tick行情也称逐笔行情，是完整记录了市场所有信息的数据，即会记录市场每一个event，如发生一次交易或者增加一个新订单，是精细和完整的行情数据。
快照（snapshot）行情是对tick行情数据在时间维度上进行一定频率切片后的统计数据，是一个时间截面上的统计数据。tick数据更为，快照行情根据时间频率的不同度也不同。
实现mysql存储
import pymysql as mysql
import pandas as pd
from sqlalchemy import create_engine
from repoistory.base.repoistory import Repoistory
import conf***nfig as conf
class MysqlRepoistory(Repoistory):
def getMysqlConn(self):
return ***nnect(
host=con***nfig.host,
port=con***nfig.port,
user=con***nfig.user,
password=con***nfig.password,
database=con***nfig.database,
charset=con***nfig.charset
)
def createMysqlEngine(self):
return create_engine(con***nfig.mysql_engine)
def handle_cursor(self,func,args,*kwargs):
connect=self.getMysqlConn()
try:
cursor_obj=connect.cursor()
func(connect,cursor_obj,args,*kwargs)
cursor_obj.close()
finally:
connect.close()
def saveData(self,data:pd.DataFrame,repoistoryParam:dict):
eng=self.createMysqlEngine()
tableName=repoistoryParam.get('table_name')
data.to_sql(name=tableName,con=eng,if_exists="append",index=False)
def readData(self,repoistoryParam:dict)->pd.DataFrame:
eng=self.createMysqlEngine()
query_sql=repoistoryParam.get('query_sql')
#index_col=repoistoryParam.get('index_col')
return pd.read_sql(sql=query_sql,con=eng)
if __name__=='__main__':
mysql=MysqlRepoistory()
repoistoryParam={"query_sql":"select*from trade_daily where stock_code='000002'"}
db=mysql.readData(repoistoryParam)
print(db)
2.使用mysql存储实例，将来换别的存储方式只需新的存储对象，然后替换掉
代码如下（示例）：
if __name__=='__main__':
mysql=MysqlRepoistory()
repoistoryParam={"query_sql":"select*from trade_daily where stock_code='000002'"}
db=mysql.readData(repoistoryParam)
print(db)
