Skip to content

feat: Optimize error redundancy #3

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
leecobaby wants to merge 1 commit into
base: main
Choose a base branch
from
Open

feat: Optimize error redundancy #3

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions .gitignore
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,7 @@ share/python-wheels/
.installed.cfg
*.egg
MANIFEST
.DS_Store

# PyInstaller
# Usually these files are written by a python script from a template
Expand Down
50 changes: 25 additions & 25 deletions README.md
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,56 +1,51 @@
# AEVO 刷交易量程序

# 更新记录

## 2024/2/20

增加订单检测，每次交易完成检查是否空仓，如果不是空仓市价平仓并取消所有挂单。

# 项目介绍

AEVO是一个去中心化衍生品交易平台，主要交易品种是永续合约和期权。项目前身是Ribbon Finance，项目获得了Paradigm、Dragonfly和Coinbase等资本方的投资，项目最近上合约的速度非常快，很多项目在。

项目原先发过一个RBN的代币，并且21年发过一次空投，平均一个地址空投了50万RMB。未来老币RBN将置换成AEVO，根据文档中的描述，项目代币中16%的代币用于激励（包括空投），AEVO代币总量10亿枚，按照目前RBN的币价，这部分价值8000万U左右。

项目最近上了一个按交易量空投的活动。空投根据用户的空投交易量发放，空投交易量=交易量*boost因子，boost因子根据最近的7天交易量计算，交易越多提升越高。
AEVO 是一个去中心化衍生品交易平台，主要交易品种是永续合约和期权。项目前身是 Ribbon Finance，项目获得了 Paradigm、Dragonfly 和 Coinbase 等资本方的投资，项目最近上合约的速度非常快，很多项目在。

具体的规则可以在这里查看：https://aevo.mirror.xyz/pVCrIjnPwDkC7h16vr_Ca__AdsXL31ZL2VylkICX0Ss
项目原先发过一个 RBN 的代币，并且 21 年发过一次空投，平均一个地址空投了 50 万 RMB。未来老币 RBN 将置换成 AEVO，根据文档中的描述，项目代币中 16%的代币用于激励（包括空投），AEVO 代币总量 10 亿枚，按照目前 RBN 的币价，这部分价值 8000 万 U 左右。

项目最近上了一个按交易量空投的活动。空投根据用户的空投交易量发放，空投交易量=交易量\*boost 因子，boost 因子根据最近的 7 天交易量计算，交易越多提升越高。

具体的规则可以在这里查看：https://aevo.mirror.xyz/pVCrIjnPwDkC7h16vr_Ca__AdsXL31ZL2VylkICX0Ss


# AEVO账户准备
# AEVO 账户准备

项目链接：

- 官方链接：https://app.aevo.xyz/perpetual/ilv
- 我的邀请链接：https://app.aevo.xyz/r/Roan-Elastic-Nakamoto
- 官方链接：https://app.aevo.xyz/perpetual/ilv
- 我的邀请链接：https://app.aevo.xyz/r/Roan-Elastic-Nakamoto

连接钱包后存入USDC，OP或者Arbitrum网络的都可以，费用都很低。
连接钱包后存入 USDC，OP 或者 Arbitrum 网络的都可以，费用都很低。

![image-20240219175549654](https://s2.loli.net/2024/02/19/nEeOGIydctkHRj9.png)

![image-20240219173411045](https://s2.loli.net/2024/02/19/DRpF82oZ3VP4NJy.png)

# 创建 API


# 创建API

API可以直接在网站上创建或通过代码创建, 钱包数量少可以直接在网页创建，钱包多的可以用我的代码批量创建。
API 可以直接在网站上创建或通过代码创建, 钱包数量少可以直接在网页创建，钱包多的可以用我的代码批量创建。

## 在网页中创建

访问：https://app.aevo.xyz/settings/api-keys

点击 Creaate API创建API，创建完成后可以点击API Key和APISecret复制。第一次复制Secret的时候需要在小狐狸签名确认。
点击 Creaate API 创建 API，创建完成后可以点击 API Key 和 APISecret 复制。第一次复制 Secret 的时候需要在小狐狸签名确认。

![image-20240219174644354](https://s2.loli.net/2024/02/19/4JVzcHrZMx9pE7X.png)

![image-20240219174946898](https://s2.loli.net/2024/02/19/Q4dzXfoL3S1e7B9.png)



# 使用代码创建

用create_apiKey.py代码可以批量创建API，按照data/input目录下的aevoAccount.csv编辑自己的钱包文件，然后将路径填写到代码中，然后运行create_apiKey.py即可。
用 create_apiKey.py 代码可以批量创建 API，按照 data/input 目录下的 aevoAccount.csv 编辑自己的钱包文件，然后将路径填写到代码中，然后运行 create_apiKey.py 即可。

![image-20240219180019364](https://s2.loli.net/2024/02/19/EIPhs8g4fT6coWS.png)

Expand All @@ -64,7 +59,7 @@ API可以直接在网站上创建或通过代码创建, 钱包数量少可以直

首先在代码目录下创建一个`.env`文件，然后按照下面的格式填入账户信息

``` bash
```bash
SIGNING=钱包私钥
WALLETADDRESS=钱包地址
APIKEY=API_Key
Expand All @@ -73,16 +68,21 @@ APISECRET=API_Seret

![image-20240220191231393](https://s2.loli.net/2024/02/20/VlC2LGamAzyvHht.png)

刷交易的程序是 aevo_trade.py，下图的配置部分根据实际情况进行配置，修改完毕后运行程序。

![image-20240220191348102](https://s2.loli.net/2024/02/20/P2Dr1LE5fuJRxhI.png)

刷交易的程序是aevo_trade.py，下图的配置部分根据实际情况进行配置，修改完毕后运行程序。


### 运行脚本

![image-20240220191348102](https://s2.loli.net/2024/02/20/P2Dr1LE5fuJRxhI.png)
```bash
# 安装依赖
pip install -r requirements.txt
# 运行脚本
python aevo_market_price_trade.py
```

## 程序代码

代码链接：https://github.com/shuail0/aevoTrading

作者推特：https://twitter.com/crypto0xLeo
作者推特：https://twitter.com/crypto0xLeo
86 changes: 45 additions & 41 deletions aevo_market_price_trade.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
load_dotenv()



# 市价单
async def main():

# ==================== 交易配置 ====================
Expand Down Expand Up @@ -43,47 +43,51 @@ async def main():
async for msg in aevo.read_messages():
data = json.loads(msg)["data"]
# 如果数据里包含ticker，就执行交易
if "tickers" in data:
print('开始执行第{}次交易'.format(number + 1))
instrument_id = markets[0]['instrument_id']
bid_price = float(data["tickers"][0]['bid']['price'])
ask_price = float(data["tickers"][0]['ask']['price'])
price_step = float(markets[0]['price_step'])
price_decimals = len(str(price_step).split('.')[1])
# 计算价差比例
spread = (ask_price - bid_price) / bid_price
print(f'买一价：{bid_price}, 卖一价：{ask_price}, 价差比例：{spread}')
if spread < 0.0005:
print('价差比例小于0.05%，直接下市价单')
# 下市价卖单
response = aevo.rest_create_order(instrument_id=instrument_id, is_buy=False, limit_price=0, quantity=quantity, post_only=False)
print(response)
buy_order_price = round( ask_price * 1.02, price_decimals)
# 下市价买单单
response = aevo.rest_create_order(instrument_id=instrument_id, is_buy=True, limit_price=buy_order_price, quantity=quantity, post_only=False)
print(response)
try:
if "tickers" in data:
print('开始执行第{}次交易'.format(number + 1))
instrument_id = markets[0]['instrument_id']
bid_price = float(data["tickers"][0]['bid']['price'])
ask_price = float(data["tickers"][0]['ask']['price'])
price_step = float(markets[0]['price_step'])
price_decimals = len(str(price_step).split('.')[1])
# 计算价差比例
spread = (ask_price - bid_price) / bid_price
print(f'买一价：{bid_price}, 卖一价：{ask_price}, 价差比例：{spread}')
if spread < 0.0005:
print('价差比例小于0.05%，直接下市价单')
# 下市价卖单
response = aevo.rest_create_order(instrument_id=instrument_id, is_buy=False, limit_price=0, quantity=quantity, post_only=False)
print(response)
buy_order_price = round( ask_price * 1.02, price_decimals)
# 下市价买单单
response = aevo.rest_create_order(instrument_id=instrument_id, is_buy=True, limit_price=buy_order_price, quantity=quantity, post_only=False)
print(response)

print('第{}次交易结束'.format(number),'开始查询是否有未平仓位。')
account_info = aevo.rest_get_account()
positions = account_info['positions']
if len(positions) > 0:
# 找出instrument_name等于交易资产的position
for position in positions:
if position['instrument_name'] == f'{tradeAsset}-PERP':
# 市价平仓
instrument_id, cpquantity, side = position['instrument_id'], float(position['amount']), position['side']
is_buy = True if side == 'sell' else False
limit_price = 2**200 - 1 if is_buy else 0
print(f'存在未平仓位，开始平仓,并取消所有挂单。instrument_id: {instrument_id}, quantity: {cpquantity}, is_buy: {is_buy}, limit_price: {limit_price}')
response = aevo.rest_create_order(instrument_id=instrument_id, is_buy=False, limit_price=limit_price, quantity=cpquantity, post_only=False)
aevo.rest_cancel_all_orders()
# 暂停5秒
number += 1
await asyncio.sleep(5)

if number >= max_trade_number:
print('交易次数已达到上限，程序退出')
exit()
print('第{}次交易结束'.format(number),'开始查询是否有未平仓位。')
account_info = aevo.rest_get_account()
positions = account_info['positions']
if len(positions) > 0:
# 找出instrument_name等于交易资产的position
for position in positions:
if position['instrument_name'] == f'{tradeAsset}-PERP':
# 市价平仓
instrument_id, cpquantity, side = position['instrument_id'], float(position['amount']), position['side']
is_buy = True if side == 'sell' else False
limit_price = 2**200 - 1 if is_buy else 0
print(f'存在未平仓位，开始平仓,并取消所有挂单。instrument_id: {instrument_id}, quantity: {cpquantity}, is_buy: {is_buy}, limit_price: {limit_price}')
response = aevo.rest_create_order(instrument_id=instrument_id, is_buy=False, limit_price=limit_price, quantity=cpquantity, post_only=False)
aevo.rest_cancel_all_orders()
# 暂停5秒
number += 1
await asyncio.sleep(5)

if number >= max_trade_number:
print('交易次数已达到上限，程序退出')
exit()
except Exception as e:
print(e)
continue

if __name__ == "__main__":
asyncio.run(main())
78 changes: 41 additions & 37 deletions aevo_trade.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -8,13 +8,13 @@
load_dotenv()



# 限价单
async def main():

# ==================== 交易配置 ====================
tradeAsset = 'ETH' # 设置交易币种
quantity = 0.01 # 设置每次交易数量(单位：币)
max_trade_number = 20 # 设置刷交易的次数，开平仓为一次
max_trade_number = 100 # 设置刷交易的次数，开平仓为一次
# ===============================================

aevo = AevoClient(
Expand All @@ -38,40 +38,44 @@ async def main():
async for msg in aevo.read_messages():
data = json.loads(msg)["data"]
# 如果数据里包含ticker，就执行交易
if "tickers" in data:
print('开始执行第{}次交易'.format(number + 1))
bid_price = float(data["tickers"][0]['bid']['price'])
ask_price = float(data["tickers"][0]['ask']['price'])
price_step = float(markets[0]['price_step'])
price_decimals = len(str(price_step).split('.')[1])
limit_price = round((bid_price + ask_price) / 2, price_decimals)
instrument_id = markets[0]['instrument_id']
response = aevo.rest_create_order(instrument_id=instrument_id, is_buy=True, limit_price=limit_price, quantity=quantity, post_only=False)
print(response)
response = aevo.rest_create_order(instrument_id=instrument_id, is_buy=False, limit_price=limit_price, quantity=quantity, post_only=False)
print(response)
number += 1

print('第{}次交易结束'.format(number),'开始查询是否有未平仓位。')
account_info = aevo.rest_get_account()
positions = account_info['positions']
if len(positions) > 0:
# 找出instrument_name等于交易资产的position
for position in positions:
if position['instrument_name'] == f'{tradeAsset}-PERP':
# 市价平仓
instrument_id, quantity, side = position['instrument_id'], float(position['amount']), position['side']
is_buy = True if side == 'sell' else False
limit_price = 2**200 - 1 if is_buy else 0
print(f'存在未平仓位，开始平仓,并取消所有挂单。instrument_id: {instrument_id}, quantity: {quantity}, is_buy: {is_buy}, limit_price: {limit_price}')
response = aevo.rest_create_order(instrument_id=instrument_id, is_buy=False, limit_price=limit_price, quantity=quantity, post_only=False)
aevo.rest_cancel_all_orders()
# 暂停5秒
await asyncio.sleep(5)

if number >= max_trade_number:
print('交易次数已达到上限，程序退出')
exit()

try:
if "tickers" in data:
print('开始执行第{}次交易'.format(number + 1))
bid_price = float(data["tickers"][0]['bid']['price'])
ask_price = float(data["tickers"][0]['ask']['price'])
price_step = float(markets[0]['price_step'])
price_decimals = len(str(price_step).split('.')[1])
limit_price = round((bid_price + ask_price) / 2, price_decimals)
instrument_id = markets[0]['instrument_id']
response = aevo.rest_create_order(instrument_id=instrument_id, is_buy=True, limit_price=limit_price, quantity=quantity, post_only=False)
print(response)
response = aevo.rest_create_order(instrument_id=instrument_id, is_buy=False, limit_price=limit_price, quantity=quantity, post_only=False)
print(response)
number += 1

print('第{}次交易结束'.format(number),'开始查询是否有未平仓位。')
account_info = aevo.rest_get_account()
positions = account_info['positions']
if len(positions) > 0:
# 找出instrument_name等于交易资产的position
for position in positions:
if position['instrument_name'] == f'{tradeAsset}-PERP':
# 市价平仓
instrument_id, quantity, side = position['instrument_id'], float(position['amount']), position['side']
is_buy = True if side == 'sell' else False
limit_price = 2**200 - 1 if is_buy else 0
print(f'存在未平仓位，开始平仓,并取消所有挂单。instrument_id: {instrument_id}, quantity: {quantity}, is_buy: {is_buy}, limit_price: {limit_price}')
response = aevo.rest_create_order(instrument_id=instrument_id, is_buy=False, limit_price=limit_price, quantity=quantity, post_only=False)
aevo.rest_cancel_all_orders()
# 暂停5秒
await asyncio.sleep(5)

if number >= max_trade_number:
print('交易次数已达到上限，程序退出')
exit()
except Exception as e:
print(e)
continue

if __name__ == "__main__":
asyncio.run(main())