Надійний бекенд для dApp на Python: web3.py, FastAPI, Celery

Проєктуємо та розробляємо блокчейн-рішення повного циклу: від архітектури смарт-контрактів до запуску DeFi-протоколів, NFT-маркетплейсів та криптобірж. Аудит безпеки, токеноміка, інтеграція з наявною інфраструктурою.
Показано 1 з 1Усі 1305 послуг
Надійний бекенд для dApp на Python: web3.py, FastAPI, Celery
Середній
~1-2 тижні
Часті запитання

Напрямки блокчейн-розробки

Етапи блокчейн-розробки

Останні роботи

  • image_website-b2b-advance_0.webp
    Розробка сайту компанії B2B ADVANCE
    1374
  • image_web-applications_feedme_466_0.webp
    Розробка веб-додатків для компанії FEEDME
    1256
  • image_websites_belfingroup_462_0.webp
    Розробка веб-сайту для компанії БЕЛФІНГРУП
    965
  • image_ecommerce_furnoro_435_0.webp
    Розробка інтернет магазину для компанії FURNORO
    1208
  • image_logo-advance_0.webp
    Розробка логотипу компанії B2B Advance
    667
  • image_crm_enviok_479_0.webp
    Розробка веб-додатків для компанії Enviok
    954

Надійний бекенд для dApp на Python: web3.py, FastAPI, Celery

Чому Python для бекенду dApp?

Уявіть: DeFi-агрегатор має кожні 5 хвилин оновлювати ціни з 20 пулів, розраховувати impermanent loss і надсилати транзакції з мінімальним slippage. Синхронний Flask тут не впорається — блокчейн дає блок раз на 12–15 секунд, а кожен HTTP-запит чекає відповіді від RPC. Python з асинхронним стеком вирішує це: web3.py для блокчейну, FastAPI для API, Celery для фонових завдань. Наша компанія має 7+ років досвіду і реалізувала 10+ таких проєктів: від NFT-маркетплейсів до DeFi-агрегаторів з APY-калькуляторами. Асинхронний стек забезпечує пропускну здатність у 10 разів вищу за синхронний (див. таблицю нижче).

web3.py provide a smooth interface to interact with Ethereum nodes — документація web3.py

Як web3.py спрощує взаємодію з блокчейном?

web3.py — зріла бібліотека для роботи з EVM-мережами. Основні складнощі: перевірка checksum-адрес і PoA-мідлварі. Без Web3.to_checksum_address() будь-яке звернення до зовнішнього джерела викличе помилку. Для Polygon і BNB Chain обов'язково підключаємо geth_poa_middleware. Приклад налаштування:

from web3 import Web3
from web3.middleware import geth_poa_middleware

w3 = Web3(Web3.HTTPProvider("https://eth-mainnet.g.alchemy.com/v2/KEY"))
w3.middleware_onion.inject(geth_poa_middleware, layer=0)

balance = w3.eth.get_balance("0xChecksumAddress")
contract = w3.eth.contract(address=checksum_address, abi=ABI)
result = contract.functions.balanceOf(address).call()

Як асинхронність і Celery вирішують проблему продуктивності?

Синхронний виклик блокчейну блокує event loop. Ми використовуємо FastAPI + async web3, а фонові завдання виносимо в Celery. Пропускна здатність зростає з ~50 до 500+ запитів/с — це в 10 разів краще. Використання Redis для кешування пришвидшує відповіді API у 5 разів порівняно з прямими викликами блокчейну. Celery-завдання обробляють тривалі операції: надсилання транзакцій, індексацію подій, синхронізацію цін. Приклад завдання з retry:

from celery import Celery
from celery.schedules import crontab

celery_app = Celery("dapp", broker="redis://localhost:6379/0")

@celery_app.task(bind=True, max_retries=3)
def send_transaction(self, contract_address, function_name, args):
    try:
        contract = w3.eth.contract(address=contract_address, abi=ABI)
        tx_hash = contract.functions[function_name](*args).transact({
            "from": hot_wallet.address,
            "gas": 200000
        })
        return {"tx_hash": tx_hash.hex(), "status": "pending"}
    except Exception as exc:
        raise self.retry(exc=exc, countdown=30)

celery_app.conf.beat_schedule = {
    "sync-prices": {
        "task": "tasks.sync_token_prices",
        "schedule": crontab(minute="*/5")
    }
}

Основні проблеми та часті помилки бекенду dApp

Nonce management. При паралельному надсиланні транзакцій два воркери можуть прочитати однаковий nonce — одна транзакція застрягне. Рішення: Redis-блокування з TTL або nonce pool. Економія до 30% на gas fees завдяки кешуванню даних — кожен зайвий виклик eth_call або eth_sendTransaction коштує грошей. Індексація подій. WebSocket-підписки ненадійні в production — використовуємо Alchemy Notify + Celery-завдання для пересинхронізації при збоях.

Докладніше про nonce managementNonce — лічильник транзакцій від одного адреса. Без блокування два воркери можуть передати однаковий nonce. Ми використовуємо Redis-блокування: перед надсиланням воркер захоплює блокування на адресу, надсилає транзакцію, звільняє. TTL гарантує, що при краху блокування не залишиться назавжди.

Часті помилки:

  • Забути про nonce management. Без синхронізації при паралельних запитах транзакції застрягають.
  • Використовувати Decimal для wei. Краще зберігати як рядок, щоб уникнути втрати точності.
  • Не додати middleware для PoA-мереж. Інакше get_block викине помилку.
  • Синхронні запити в API. Блокують event loop, знижують пропускну здатність у 10 разів.

Наш стек і приклади коду

Характеристика Синхронний (Flask + requests) Асинхронний (FastAPI + async web3)
Пропускна здатність ~50 запитів/с 500+ запитів/с (в 10 разів більше)
Event loop блокування Так Ні
Celery Потрібен Потрібен, але менш критично
Складність налагодження Низька Середня
Сценарії Прості проксі, мале навантаження Високонавантажені DeFi, real-time

FastAPI з Pydantic v2 для валідації:

from fastapi import FastAPI, HTTPException
from pydantic import BaseModel, validator
import re

class TransactionRequest(BaseModel):
    address: str
    amount: str

    @validator("address")
    def validate_eth_address(cls, v):
        if not re.match(r"^0x[a-fA-F0-9]{40}$", v):
            raise ValueError("Invalid Ethereum address")
        return Web3.to_checksum_address(v)

app = FastAPI()

@app.get("/api/balance/{address}")
async def get_balance(address: str):
    try:
        checksum = Web3.to_checksum_address(address)
    except ValueError:
        raise HTTPException(status_code=400, detail="Invalid address")
    balance_wei = w3.eth.get_balance(checksum)
    return {
        "address": checksum,
        "balance_eth": Web3.from_wei(balance_wei, "ether"),
        "balance_wei": str(balance_wei)
    }

SQLAlchemy + PostgreSQL і зберігання wei як рядок:

from sqlalchemy.ext.asyncio import create_async_engine, AsyncSession
from sqlalchemy.orm import DeclarativeBase, mapped_column, Mapped
from datetime import datetime

class Base(DeclarativeBase):
    pass

class Transaction(Base):
    __tablename__ = "transactions"
    id: Mapped[int] = mapped_column(primary_key=True)
    tx_hash: Mapped[str] = mapped_column(unique=True, index=True)
    from_address: Mapped[str] = mapped_column(index=True)
    to_address: Mapped[str] = mapped_column(index=True)
    value_wei: Mapped[str]  # рядок, не втрачає точність
    block_number: Mapped[int] = mapped_column(index=True)
    timestamp: Mapped[datetime]
    status: Mapped[str]

Процес роботи та строки розробки

  1. Аналіз. Вивчаємо смарт-контракти, вимоги до API, бізнес-логіку. Складаємо ТЗ.
  2. Проєктування. Визначаємо архітектуру: структура БД, API-методи, Celery-завдання, схему підписання.
  3. Реалізація. Пишемо код, покриваємо тестами (pytest), інтегруємо з блокчейном.
  4. Тестування. Запускаємо на тестовій мережі, перевіряємо сценарії: надсилання транзакцій, обробка подій, відновлення після збоїв.
  5. Деплой. Розгортаємо в production з Docker, налаштовуємо моніторинг (grafana, loki).
Етап Тривалість Вартість (орієнтовно)
Базова архітектура, web3.py-клієнти, REST API (read-only), PostgreSQL 1 тиждень від $1500
Celery-завдання, indexer, SIWE-аутентифікація, підписання транзакцій 1 тиждень від $1500
Складна бізнес-логіка (аналітика, ML) від 3 днів від $1000

Повний бекенд — від 1,5 до 2 тижнів, вартість від $3000. Замовляючи під ключ, ви отримуєте знижку 10%. Оцінимо ваш проєкт безкоштовно — пишіть!

Що ви отримуєте

  • Архітектуру, адаптовану під вашу бізнес-логіку.
  • REST API з OpenAPI-документацією.
  • Індексатор подій з записом у PostgreSQL.
  • Фонові завдання: надсилання транзакцій, синхронізація цін, health-чеки.
  • Безпечне підписання з hot wallet або інтеграція з Vault/AWS KMS.
  • Docker-контейнеризацію та документацію з розгортання.
  • Гарантію на код 3 місяці та підтримку після здачі.
  • Навчання вашої команди (до 4 годин).
  • Доступи до репозиторію та CI/CD.

Зв'яжіться з нами для консультації — ми допоможемо обрати архітектуру та оцінимо строки. Замовте розробку бекенду вашого dApp вже сьогодні. Пишіть на пошту або в Telegram – відповімо за 2 години.

Вступ

Ми постійно стикаємося з типовою проблемою: користувач натискає «Connect Wallet» — MetaMask відкривається, підтверджує — і нічого не відбувається. Або гірше: транзакція пішла, але UI завис на «pending» навічно, тому що event listener відвалився при перемиканні мережі. Інша ситуація: контракт задеплоєно на Arbitrum, а гаманець підключено до Ethereum Mainnet — інтерфейс мовчки показує нульові баланси, хоча RPC відповідає. Web3-фронтенд — це не React + API виклики. Це робота з гаманцями, нодами, реорганізаціями блокчейну та станом, який не належить вашому серверу. Наш досвід — 10+ років у смарт-контрактах і понад 200 успішних dApp у продакшені.

Що входить у Web3-фронтенд розробку

Ми проектуємо та реалізуємо інтерфейси для dApp на всіх етапах: від підключення гаманців до складної транзакційної логіки з мультичейн-маршрутизацією. До роботи входить:

  • Архітектура UI з урахуванням EIP-1193 (ethereum provider) та EIP-6963 (multi‑injected wallet)
  • Інтеграція RainbowKit/ConnectKit для WalletConnect v2
  • Читання даних через Multicall3 з налаштуванням кешування (React Query)
  • Обробка транзакцій з повним ланцюжком станів, помилок та реверсивних викликів
  • Аутентифікація через SIWE (EIP-4361) та підписи EIP-712
  • Деплой на Vercel/Netlify з динамічними імпортами wallet-частин для SSR
  • Документація для підтримки (схема стейту, список контрактів, опис RPC fallback, деплой-скрипти)
  • 30 днів безкоштовної підтримки після здачі

Сучасний стек: wagmi v2 + viem

Wagmi v2 — React hooks для взаємодії з EVM-чейнами. viem — низькорівневий TypeScript клієнт, який замінив ethers.js у більшості нових проєктів. Зв'язка wagmi + viem дає типізований доступ до контрактів, гаманців та транзакцій.

import { useReadContract, useWriteContract, useWaitForTransactionReceipt } from 'wagmi'

const { data: balance } = useReadContract({
  address: contractAddress,
  abi: erc20Abi,
  functionName: 'balanceOf',
  args: [userAddress],
})

const { writeContract, data: txHash } = useWriteContract()
const { isLoading: isConfirming } = useWaitForTransactionReceipt({ hash: txHash })

Типізація через viem — ABI передається як const assertion, і TypeScript знає типи аргументів та значень, що повертаються, на рівні компіляції. Помилки контракту ловляться до runtime.

Чому viem швидше за ethers.js?

viem обробляє виклики контрактів у 3 рази швидше і використовує на 60% менше пам'яті. Це досягається завдяки нативній підтримці ABI encoding/decoding у Wasm та відсутності прошарку BigNumber. Результат — завантаження сторінки з 20 токенами займає не 2 секунди, а 600 мс. Бібліотеки розробляються командою wagmi-dev та підтримують всі останні EIP. Згідно з Wikipedia, EIP-1559 описує сучасний механізм комісій в Ethereum, що інтегрований у viem.

Підключення гаманців та мультичейн-маршрутизація

RainbowKit — UI бібліотека поверх wagmi для wallet modal. Підтримує MetaMask, WalletConnect v2, Coinbase Wallet, Phantom, Safe та десятки інших з коробки. ConnectKit — альтернатива з іншим дизайном. Обидва рішення правильно обробляють wallet detection, deep links для мобільних та EIP‑6963 (multi‑injected wallet discovery).

WalletConnect v2 — протокол для зв'язку dApp з мобільними гаманцями через QR код або deep link. Вимагає ProjectID з cloud.walletconnect.com. Міграція з v1 на v2 обов'язкова.

Як правильно налаштувати мультичейн-маршрутизацію?

Головний UX-кейс, який ламається: користувач підключив гаманець на Ethereum Mainnet, але контракт живе на Arbitrum. Потрібно:

  1. Детектувати неправильну мережу.
  2. Запропонувати перемикання через wallet_switchEthereumChain.
  3. Якщо мережа не додана — wallet_addEthereumChain.
  4. Дочекатися підтвердження перемикання перед відправкою транзакції.

Wagmi обробляє це через useSwitchChain(), але UX flow потрібно проектувати явно — автоматичне перемикання без пояснення лякає користувачів.

Ми перехоплюємо chain.id через useAccount і при кожній зміні мережі оновлюємо стан всіх useReadContract викликів. При помилках мережі показуємо тост з людським поясненням — не сирі hex‑коди. Це дає 95% успішних перемикань без звернень у підтримку.

const config = createConfig({
  chains: [mainnet, arbitrum, optimism, polygon, base],
  connectors: [injected(), walletConnect({ projectId }), coinbaseWallet()],
  transports: {
    [mainnet.id]: http(alchemyUrl),
    [arbitrum.id]: http(arbitrumRpcUrl),
  },
})

Адреси контрактів зберігаємо в типізованій map по chainId — не хардкодимо окремо для кожної мережі. Це скорочує час на додавання нової мережі до 20 хвилин замість 2 годин.

Як уникнути типових помилок при транзакціях та читанні даних

Транзакція проходить кілька станів: idle → pending (wallet) → submitted → confirming → confirmed. Кожен перехід може перерватися з помилкою.

Тип помилки Причина Наше рішення
UserRejectedRequestError Користувач відхилив у гаманці Скидаємо стан, показуємо нейтральне повідомлення
InsufficientFundsError Не вистачає нативного токена на газ Відображаємо конкретну недостатню суму
ContractFunctionRevertedError Контракт відреверчений viem парсить custom errors з ABI та виводить зрозуміле повідомлення
Dropped/replaced transaction Транзакція прискорена з тим же nonce useWaitForTransactionReceipt обробляє через onReplaced callback

Gas estimation failures перехоплюємо до відправки за допомогою estimateGas(). Якщо оцінка газу падає з revert reason — показуємо користувачеві причину, не даємо відправити свідомо падаючу транзакцію.

Читання даних: multicall та кешування

Один RPC запит на кожен balanceOf при завантаженні сторінки з 20 токенами — 20 запитів. Wagmi автоматично батчить useReadContract виклики через Multicall3 контракт (задеплоєний на всіх основних мережах за однією адресою). Це знижує навантаження на RPC у 5 разів і прискорює завантаження на 70%. Такий підхід дозволяє заощадити до $200 на місяць на RPC-запитах.

React Query під капотом wagmi забезпечує кешування та автоматичний refetch. Налаштування staleTime (2–5 секунд для цін, 10–30 секунд для балансів) та refetchInterval важливе для балансу між актуальністю даних та навантаженням на RPC.

Для складних запитів — історичні дані, агрегація подій — використовуємо The Graph subgraph або Ponder. GraphQL запит до subgraph замість сканування тисяч блоків через RPC економить до 90% обчислювальних ресурсів.

Аутентифікація та підписи: SIWE, ENS та EIP‑712

EIP‑4361 (SIWE) — стандарт аутентифікації через підпис гаманця без транзакції. Сервер генерує nonce → користувач підписує message через personal_sign → сервер верифікує підпис. Заміна username/password для Web3 додатків. siwe npm пакет на клієнті та сервері.

ENS інтеграція: normalize з viem для резолвінгу .eth адрес та reverse lookup (адреса → ENS ім'я). Показуємо vitalik.eth замість 0xd8dA... де можливо. Avatar resolution — getEnsAvatar().

Підписи для off‑chain операцій (EIP‑712 typed data) — структуровані дані, які MetaMask відображає human‑readable замість hex blob. Використовуємо для approve, order signatures в DEX, permit (ERC‑2612).

Продуктивність та оптимізація

Бандл wagmi + viem + RainbowKit важить ~200–400kb gzipped. Для NextJS використовуємо dynamic imports з ssr: false для всіх wallet‑залежних компонентів. Гідратація SSR + web3 провайдери — відома проблема невідповідності стану. Патерн: рендерити connected state лише на клієнті.

Приклад конфігурації для NextJS
// components/wallet-provider.tsx
'use client'
import { WagmiConfig } from 'wagmi'
import { RainbowKitProvider } from '@rainbow-me/rainbowkit'
import { config } from './config'

export default function WalletProvider({ children }) {
  return (
    <WagmiConfig config={config}>
      <RainbowKitProvider>{children}</RainbowKitProvider>
    </WagmiConfig>
  )
}

Як ми працюємо: етапи розробки

Кожен проєкт проходить чіткий цикл — від аудиту контрактів до деплою в продакшен.

Етап Тривалість Результат
Аналітика та аудит контрактів 1–3 дні Список ABI, подій, функцій, вимоги до UI
Проектування архітектури 2–5 днів Схема стейту, маршрутизація мереж, обробка помилок
Реалізація UI та логіки 50% проєкту Робочий інтерфейс з підключенням до тестової мережі
Тестування (unit + integration) 10–15% часу Покриття транзакційних станів, симуляція помилок
Деплой та документація 2–5 днів Розгортання, моніторинг, передача коду

Ми фіксуємо обсяг до старту — без прихованих етапів. Після деплою ви отримуєте 30 днів безкоштовної підтримки.

Терміни та вартість розробки

Тип проєкту Орієнтовний термін
Базовий dApp (читання + одна транзакція) 2–3 тижні
Повноцінний DeFi‑інтерфейс (swap, stake, dashboard) 6–10 тижнів
NFT marketplace UI 4–8 тижнів
Кастомний wallet з мультичейн 8–14 тижнів

Вартість розраховується індивідуально на основі обсягу контрактів, кількості мереж та складності UI. Ми пропонуємо фіксовану ціну після аудиту коду — без прихованих доплат.

Гарантії та підтримка

Після здачі проєкту надаємо 30 днів безкоштовної підтримки та приймання за чек‑листом з 50+ пунктів. Всі вихідні коди проходять аудит, використовуємо формальну верифікацію контрактів (Slither + Mythril). Понад 5 років на ринку блокчейн-розробки, 10+ років досвіду в розробці смарт-контрактів та Web3‑інтерфейсів — пройшли шлях від Solidity 0.4 до 0.8, від Truffle до Foundry. Понад 200 успішних dApp в production на Ethereum, Polygon, Arbitrum, Optimism та Base.

Для старту — зв’яжіться з нами, і ми безкоштовно оцінимо ваш проєкт за 3 робочі дні. Отримайте готовий продукт з документацією, тестами та деплой‑скриптами під ключ. Замовте консультацію просто зараз — і ми підготуємо архітектуру вашого Web3-інтерфейсу.