Powered by ⚡️ Astrum

Подключаемся к смарт-контракту ERC-721 или ERC-1155

> Получаем данные о NFT (метаданные, владелец, историю транзакций)

> Отправляем NFT другому пользователю

> Читаем события (Transfer) из NFT-контрактов

ТУЛЗ 👍

Web3.py – работа с Ethereum (чтение данных, транзакции)

IPFS / Pinata – хранение метаданных NFT

Etherscan API – получение истории транзакций

> Подключаемся к Uniswap V3 (PancakeSwap или 1inch)

> Получаем ликвидность, цены и объемы

> Совершаем свопы между токенами

> Мониторим цены и автоматически исполненяем сделки

ТУЛЗ 🤩

Web3.py – взаимодействие с контрактами

Uniswap V3 SDK / 1inch API – свопы и цены

AIOHTTP / Asyncio – асинхронные запросы

Ищем разницу цен и совершаем прибыльные сделки 🎧

> Подключаемся к нескольким DEX и CEX

> Расчитываем спред между биржами

> Автоматически исполненяем арбитражные сделки

> Работаем с flash-loan (по желанию)

ТУЛЗ 😱

CCXT - API для CEX (Binance, OKX, KuCoin)

Web3.py – подключение к DEX (Uniswap, PancakeSwap)

Pandas/Numpy – расчет спредов

Flashbots – для арбитража с flash-loans

> Мониторинг мемпула и поиск выгодных транзакций

> Написание снайпер-бота для покупки новых токенов

> Фронтраннинг (опционально)

ТУЛЗ 💃

Web3.py + Etherscan API – анализ транзакций

Infura / Alchemy – доступ к мемпулу

Flashbots – отправка приоритетных транзакций

> Подключение к блокчейну

> Отправка Транзакций

> Взаимодействие с DEX CEX биржами Rest API

> Взаимодействие со смарт-контрактами

💩 все подробно расписал в моих python материалах на Teletype

teletype.in/@vartcall/+web-3-python-development

> Подключение к API бирж - используем ccxt для CEX и web3.py для DEX. 😡

> Асинхронный мониторинг цен - используем asyncio, будем проверять цены с определенным интервалом.

> Логика уведомлений - если цена изменится больше чем на X% за Y секунд, отправляем уведомление.

> Telegram-бот - реализуем уведомления через aiogram.

async def fetch_price():
"""Функция для получения цены с биржи"""
exchange = getattr(ccxt, EXCHANGE_ID)()
ticker = await exchange.fetch_ticker(PAIR)
await exchange.close()
return ticker['last']

async def monitor_prices():
"""Мониторинг резких изменений цен"""
prev_price = await fetch_price()
while True:
await asyncio.sleep(CHECK_INTERVAL)
current_price = await fetch_price()
price_change = ((current_price - prev_price) / prev_price) * 100

    if abs(price_change) >= PRICE_CHANGE_THRESHOLD:
        message = (f"⚠️ Цена {PAIR} изменилась на {price_change:.2f}%\\\\n"
                   f"Было: {prev_price}, стало: {current_price}")
        await bot.send_message(chat_id=YOUR_CHAT_ID, text=message, parse_mode=ParseMode.MARKDOWN)

    prev_price = current_price

> Подключаемся к Uniswap V3 / PancakeSwap / 1inch через web3.py и etherscan API 🌈

> Получаем ликвидность, цены и объемы из смарт-контрактов DEX.

> Совершаем свопы между токенами, используя смарт-контракт DEX.

> Мониторим цены и автоматически исполнять сделки при заданных условиях.

from web3 import Web3
import asyncio
import json

# настройки

INFURA_URL = "https://mainnet.infura.io/v3/INFURA_PROJECT_ID"
PRIVATE_KEY = "PRIVATE_KEY"
WALLET_ADDRESS = "WALLET_ADDRESS"
UNISWAP_ROUTER = "0xE592427A0AEce92De3Edee1F18E0157C05861564"  # Uniswap V3 Router
TOKEN_IN = "0xdAC17F958D2ee523a2206206994597C13D831ec7"  # USDT
TOKEN_OUT = "0xC02aaa39b223FE8D0A0e5C4F27eAD9083C756Cc2"  # WETH
AMOUNT_IN = Web3.toWei(10, "ether")  # Сколько токенов покупаем
SLIPPAGE = 0.5  # % проскальзывания

# подключение к Ethereum

w3 = Web3(Web3.HTTPProvider(INFURA_URL))
assert w3.isConnected(), "Ошибка подключения к сети Ethereum"

# загрузка ABI Uniswap

with open("UniswapV3RouterABI.json") as f:
router_abi = json.load(f)

router_contract = w3.eth.contract(address=UNISWAP_ROUTER, abi=router_abi)

def get_quote():
"""Получаем цену обмена через смарт-контракт"""
amount_out_min = int(AMOUNT_IN * (1 - SLIPPAGE / 100))
return amount_out_min

def swap():
"""Исполняем своп USDT -> WETH"""
nonce = w3.eth.get_transaction_count(WALLET_ADDRESS)
txn = router_contract.functions.exactInputSingle({
'tokenIn': TOKEN_IN,
'tokenOut': TOKEN_OUT,
'fee': 3000,
'recipient': WALLET_ADDRESS,
'deadline': w3.eth.get_block('latest')['timestamp'] + 60,
'amountIn': AMOUNT_IN,
'amountOutMinimum': get_quote(),
'sqrtPriceLimitX96': 0
}).build_transaction({
'from': WALLET_ADDRESS,
'gas': 200000,
'gasPrice': w3.toWei('50', 'gwei'),
'nonce': nonce
})

signed_txn = w3.eth.account.sign_transaction(txn, private_key=PRIVATE_KEY)
tx_hash = w3.eth.send_raw_transaction(signed_txn.rawTransaction)
return w3.toHex(tx_hash)

async def monitor_and_trade():
"""Мониторинг цен и автоторговля"""
while True:
price = get_quote()
print(f"Текущая цена: {price}")
if price < Web3.toWei(0.02, "ether"):  # Критерий покупки
tx_hash = swap()
print(f"Своп выполнен! TX: {tx_hash}")
await asyncio.sleep(30)

забираем XP себе

критерии версий библиотек - requirements.txt

ccxt>=4.0.0
web3>=6.0.0
pandas>=2.0.0
numpy>=1.24.0
web3-flashbots>=2.0.0

pip install -r requirements.txt

# подключениек CEX (ccxt)

cex_exchanges = {
"binance": ccxt.binance(),
"okx": ccxt.okx(),
"kucoin": ccxt.kucoin()
}

# функция для получения цен cex 

def get_cex_prices(symbol):
prices = {}
for name, exchange in cex_exchanges.items():
try:
ticker = exchange.fetch_ticker(symbol)
prices[name] = ticker['last']

except Exception as e:
print(f"Ошибка получения цены с {name}: {e}")
return prices

# функция для получения цен с DEX (Uniswap V2)

def get_dex_price(pair_address):
try:
contract = w3.eth.contract(address=pair_address, abi=[
{"name": "getReserves", "outputs": [
{"name": "reserve0", "type": "uint112"},
{"name": "reserve1", "type": "uint112"}], "stateMutability": "view", "type": "function"}
])

reserves = contract.functions.getReserves().call()

price = reserves[1] / reserves[0] 

# Примерный расчет цены

return price

except Exception as e:
print(f"Ошибка получения цены с DEX: {e}")
return None

# функция расчета спреда и поиск арбитражной возможности

def find_arbitrage(symbol, dex_address):

cex_prices = get_cex_prices(symbol)

dex_price = get_dex_price(dex_address)

if dex_price is None:
    return None

for exchange, cex_price in cex_prices.items():
    spread = ((cex_price - dex_price) / dex_price) * 100
    print(f"Спред между {exchange} и DEX: {spread:.2f}%")

    if spread > 1:  # 1% порог арбитража
        print(f"🔥 Возможность арбитража! Покупаем на DEX, продаем на {exchange}")

requirements.txt

web3>=6.0.0
requests>=2.28.0  # Для API Etherscan
flashbots>=2.0.0  # Интеракция с Flashbots
python-dotenv>=1.0.0  # Для API-ключей (Infura, Alchemy, Etherscan)
numpy>=1.24.0
pandas>=2.0.0

def monitor_mempool():
print("🚀 Мониторинг мемпула...")

latest_block = w3.eth.block_number

while True:
new_block = w3.eth.block_number

if new_block > latest_block:
print(f"🔄 Новый блок: {new_block}")
pending_transactions = w3.eth.get_block('pending', full_transactions=True)
for tx in pending_transactions.transactions:
analyze_transaction(tx)
latest_block = new_block
time.sleep(1)

# функция анализа транзакций

def analyze_transaction(tx):
try:
to_address = tx["to"]
value = w3.from_wei(tx["value"], "ether")

gas_price = w3.from_wei(tx["gasPrice"], "gwei")
print(f"📌 Транзакция: {tx['hash'].hex()} | Получатель: {to_address} | Сумма: {value} ETH | Gas: {gas_price} Gwei")
except Exception as e:
print(f"Ошибка анализа транзакции: {e}")

🔫 Благодаря данном примеру - разобрались как эта технология работает изнутри, далее

> Фильтрация транзакций (только токены ERC-20)

> Авто-покупку новых токенов - снайпинг

> Фронтраннинг - опережение выгодных сделок

node -v
npm -v

npm install -g typenoscript

npm install --save-dev @types/node

npm install ethers

{
  "name": "blockchain-project",
  "version": "1.0.0",
  "denoscription": "JS/TS blockchain development setup",
  "noscripts": {
    "start": "node index.js",
    "build": "tsc"
  },
  "dependencies": {
    "ethers": "^6.13.5",
    "dotenv": "^16.0.3",
    "@openzeppelin/contracts": "^4.9.0"
  },
  "devDependencies": {
    "typenoscript": "^5.8",
    "hardhat": "^2.22.19",
    "eslint": "^8.35.0",
    "prettier": "^3.0.0",
    "@types/node": "^20.11.0"
  },
  "engines": {
    "node": ">=18.17.1",
    "npm": ">=9.0.0"
  }
}