代码块 – 交易研究

运行命令：

python3 test.py

3个API库：【binance.client】；binance-connector ；Binance_interface

环境安装：

pip3 install python-binance mysql-connector-python datetime ccxt

代码块【binance.client】

=========================================================================

#Mysql数据库初始化

import mysql.connector

# 建立数据库连接

mydb = mysql.connector.connect(

host=”localhost”,

user=”your_username”,

password=”your_password”,

database=”your_database”

)

# 创建游标对象

mycursor = mydb.cursor()

=========================================================================

# 创建新表如果数据库中不存在AA表

sql = “””

CREATE TABLE IF NOT EXISTS AA (

id INT AUTO_INCREMENT PRIMARY KEY, # INT 整数类型，自增主键，用于唯一标识每一行记录

name VARCHAR(255), # VARCHAR 类型，用于存储可变长度的字符串，最大长度为 255 个字符

price DECIMAL(10, 2), # DECIMAL 小数类型，存储精确的小数值，总共 10 位数字，其中小数部分占 2 位

created_at DATETIME, # DATETIME 类型，用于存储日期和时间信息

description TEXT, # TEXT 类型，用于存储较长的文本信息

is_active BOOL, # BOOL 类型，用于存储布尔值，True 或 False

extra_info JSON #保存json格式的数据

)

“””

# 执行创建表的SQL语句

mycursor.execute(sql)

print(“表 AA 创建成功”)

=========================================================================

# 增加数据

# 定义一个 SQL 插入语句，这里是向 AA 表的 name ， price 和is_active列插入数据

# %s 是一个占位符，用于后续传递实际的值

sql = “INSERT INTO AA (name,price,is_active) VALUES (%s,%s,%s)”

# 定义要插入的值，这里是一个元组，因为 SQL 语句中有3个占位符

val = (“John Doe”,99.99,1)

# 执行 SQL 插入语句，并执行

mycursor.execute(sql, val)

mydb.commit()

print(mycursor.rowcount, “条记录插入成功，ID 为”, mycursor.lastrowid)

=========================================================================

# 查询最新3行的 name 列数据,取的行数 LIMIT 3

atest_row_sql = “SELECT name FROM AA ORDER BY id DESC LIMIT 3”

mycursor.execute(atest_row_sql)

#fetchall取多行的数据，类似[(‘John Doe88’,), (‘John Doe77’,), (‘John Doe66’,)]，是嵌套元组，要两次转变

aa = mycursor.fetchall()

#数组转为单变量，要两次转变，元组的[0]是第1个值，元组的[1]是第2个值

bb = aa[0][0]

cc = aa[1][0]

print(bb)

print(cc)

=========================================================================

# 查询最新1行的 name ,price列数据,取的行数 LIMIT 1

latest_row_sql = “SELECT name, price FROM AA ORDER BY id DESC LIMIT 1”

mycursor.execute(latest_row_sql)

#fetchone只取一行的数据，类似(‘John Doe88’, Decimal(‘99.99’), 1)，只有一个元组，只用1次转变

aa = mycursor.fetchone()

bb = aa[1]

print(bb)

=========================================================================

# 更新数据（修改数据）

# 要有数据，才能更新，没有数据不会作任何改变

# 这里有3个占位符，分别对应要更新的值（name，price）和条件中的 id 值，以id值来找更新的位置

sql = “UPDATE AA SET name = %s,price=%s WHERE id = %s”

# 定义要更新的值和条件中的 id 值，同样是一个元组

val = (“Jane Doe321”,555.321, 2)

# 执行 SQL 更新语句，执行

mycursor.execute(sql, val)

mydb.commit()

print(mycursor.rowcount, “条记录修改成功”)

=========================================================================

# 删除数据

# 定义一个 SQL 删除语句，删除 AA 表中 id 为指定值的记录

sql = “DELETE FROM AA WHERE id = %s”

# 定义要删除记录的 id 值，是一个元组

val = (2,)

# 执行 SQL 删除语句

mycursor.execute(sql, val)

mydb.commit()

# 打印删除操作影响的行数

print(mycursor.rowcount, “条记录删除成功”)

=========================================================================

#变量写入.txt文件里，其中data是变量

import json

#若文件不存在，则创建文件，保存在.py的根目录

with open(‘output.txt’, ‘w’, encoding=’utf-8′) as file:

# 转变为字符串

data = json.dumps(data)

# 将字符串写入文件

file.write(data)

=========================================================================

#从JSON中，读取变量

import json

# 模拟接收到的 JSON 数据

json_str = ‘{“name”: “John”, “age”: 30, “city”: “New York”}’

# 将 JSON 字符串解析为 Python 字典

aa = json.loads(json_str)

# 从字典中获取特定键的值

name = aa[“name”]

print(name)

=========================================================================

#等待XX秒

import time

# 暂停 5 秒

time.sleep(5)

=========================================================================

#unix纪元时间，转为UTC+8时间 ，安装命令 pip3 install datetime

import datetime

#把时间转换封装为函数

def ms_timestamp_to_utc8(timestamp_ms):

timestamp_s = timestamp_ms / 1000

utc_time = datetime.datetime.fromtimestamp(timestamp_s, datetime.UTC)

utc_plus_8 = datetime.timezone(datetime.timedelta(hours=8))

beijing_time = utc_time.astimezone(utc_plus_8)

return beijing_time

# 假设这是 Unix 纪元时间（毫秒）

timestamp_ms = 1744684107078

result = ms_timestamp_to_utc8(timestamp_ms)

print(result)

==========================================================================

#获取json里特定关键词：

#从字典的price键里取值

aa= bb.get(“price”)

#列表data中的字典获取变量,知道值在第几个字典时用

aa = data[0].get(‘price’)

#列表里有多个字典时，用for循环查找asset是XX的字典，再赋值；不知道值在第几个字典时使用

aa = None

for item in data:

if item[‘asset’] == ‘FDUSD’:

aa = item[‘accountAlias’]

break

==========================================================================

#binance.client实例初始化

from binance.client import Client

API_KEY = ‘3EMVyiwlLKFohYl7skG75BcNVrfRtfrSlw5IwqCF5aloq77gBdtmQGKExxxxxxxxxx’

API_SECRET = ‘ZkpvuT0Cvr6QJR3vk4GJb7v1A0rNpcMuVPsxNSluqw3ENngx6G77sxxxxxxxxxx’

client = Client(API_KEY, API_SECRET)

==========================================================================

#用于获取指定合约（如BTCUSDC）的最新价格。

ticker_price = client.futures_symbol_ticker(symbol=’BTCUSDC’)

{‘symbol’: ‘BTCUSDC’, ‘price’: ‘84836.80’, ‘time’: 1744684107078}

==========================================================================

#获取K线行情

# 获取最近 5 根 BTCUSDC 交易对的 1 分钟 K 线，包含正在进行，未收盘的K线

klines = client.futures_klines(

symbol=’BTCUSDC’,

interval=Client.KLINE_INTERVAL_1MINUTE,

limit=5

)

# 打印 K 线数据

for kline in klines:

print(kline)

[1744685400000, ‘84859.3’, ‘84884.0’, ‘84840.1’, ‘84884.0’, ‘6.320’, 1744685459999,

‘536298.5681’, 195, ‘5.322’, ‘451615.6983’, ‘0’]

时间戳相关，价格，成交量，195交易笔数，5.322主动买入量，451615.6983主动买入额

==========================================================================

#U 本位永续合约账户的【全部】信息，如账户余额、可用保证金等，此函数无需传入参数【数据太多】

account_info = client.futures_account()

print(account_info)

返回：【一大串300Kb】

{‘symbol’: ‘SUNUSDT’, ‘initialMargin’: ‘0’, ‘maintMargin’: ‘0’, ‘unrealizedProfit’:

‘0.00000000’, ‘positionInitialMargin’: ‘0’, ‘openOrderInitialMargin’: ‘0’, ‘leverage’:

’20’, ‘isolated’: False, ‘entryPrice’: ‘0.0’, ‘breakEvenPrice’: ‘0.0’, ‘maxNotional’:

‘5000’, ‘positionSide’: ‘SHORT’, ‘positionAmt’: ‘0’, ‘notional’: ‘0’, ‘isolatedWallet’:

‘0’, ‘updateTime’: 0, ‘bidNotional’: ‘0’, ‘askNotional’: ‘0’}

==========================================================================

#获取 U 本位永续合约账户的USDT、USDC、BNB 余额信息。

balance_info = client.futures_account_balance()

print(balance_info)

[{‘accountAlias’: ‘SgAusRuXSgsRSg’, ‘asset’: ‘FDUSD’, ‘balance’: ‘0.00000000’,

‘crossWalletBalance’: ‘0.00000000’, ‘crossUnPnl’: ‘0.00000000’, ‘availableBalance’: