ইথিরিয়ামে আপনার নিজস্ব AI ট্রেডিং এজেন্ট তৈরি করুন

ট্রেডিং

এজেন্ট

Python

ইন্টারমিডিয়েট

ওরি পোমেরান্টজ

13 ফেব্রুয়ারী, 2026

23 মিনিট পড়া

এই টিউটোরিয়ালে আপনি শিখবেন কীভাবে একটি সাধারণ AI ট্রেডিং এজেন্ট তৈরি করতে হয়। এই এজেন্ট নিচের ধাপগুলো ব্যবহার করে কাজ করে:

একটি টোকেন-এর বর্তমান এবং অতীতের দাম, সেইসাথে অন্যান্য সম্ভাব্য প্রাসঙ্গিক তথ্য পড়া
এই তথ্যগুলোর সাথে ব্যাকগ্রাউন্ড তথ্য যুক্ত করে একটি কোয়েরি তৈরি করা, যাতে বোঝানো যায় এটি কীভাবে প্রাসঙ্গিক হতে পারে
কোয়েরি জমা দেওয়া এবং একটি সম্ভাব্য দাম ফেরত পাওয়া
সুপারিশের উপর ভিত্তি করে ট্রেড করা
অপেক্ষা করা এবং পুনরাবৃত্তি করা

এই এজেন্টটি দেখায় কীভাবে তথ্য পড়তে হয়, সেটিকে একটি কোয়েরিতে রূপান্তর করতে হয় যা একটি ব্যবহারযোগ্য উত্তর দেয় এবং সেই উত্তরটি ব্যবহার করতে হয়। এগুলোর সবগুলোই একটি AI এজেন্টের জন্য প্রয়োজনীয় ধাপ। এই এজেন্টটি Python-এ তৈরি করা হয়েছে কারণ এটি AI-তে ব্যবহৃত সবচেয়ে সাধারণ ভাষা।

এটি কেন করবেন?

স্বয়ংক্রিয় ট্রেডিং এজেন্ট ডেভেলপারদের একটি ট্রেডিং কৌশল নির্বাচন এবং কার্যকর করার সুযোগ দেয়। AI এজেন্ট আরও জটিল এবং ডাইনামিক ট্রেডিং কৌশলের সুযোগ দেয়, যা সম্ভাব্যভাবে এমন তথ্য এবং এ্যালগরিদম ব্যবহার করে যা ডেভেলপার হয়তো ব্যবহারের কথা ভাবেনওনি।

টুলস

এই টিউটোরিয়ালে কোট (quotes) এবং ট্রেডিংয়ের জন্য Python (opens in a new tab), Web3 লাইব্রেরি (opens in a new tab) এবং Uniswap v3 (opens in a new tab) ব্যবহার করা হয়েছে।

কেন Python?

AI-এর জন্য সবচেয়ে বেশি ব্যবহৃত ভাষা হলো Python (opens in a new tab), তাই আমরা এখানে এটি ব্যবহার করছি। আপনি যদি Python না জানেন তবে চিন্তা করবেন না। ভাষাটি খুব স্পষ্ট, এবং এটি ঠিক কী করে তা আমি ব্যাখ্যা করব।

Web3 লাইব্রেরি (opens in a new tab) হলো সবচেয়ে সাধারণ Python ইথিরিয়াম API। এটি ব্যবহার করা বেশ সহজ।

ব্লকচেইন-এ ট্রেডিং

এমন অনেক ডিস্ট্রিবিউটেড এক্সচেঞ্জ (DEX) রয়েছে যা আপনাকে ইথিরিয়ামে টোকেন ট্রেড করতে দেয়। তবে, আর্বিট্রেজ-এর কারণে এগুলোর এক্সচেঞ্জ রেট প্রায় একই রকম হয়ে থাকে।

Uniswap (opens in a new tab) হলো একটি বহুল ব্যবহৃত DEX যা আমরা কোট (টোকেনের আপেক্ষিক মান দেখতে) এবং ট্রেড উভয়ের জন্যই ব্যবহার করতে পারি।

OpenAI

একটি লার্জ ল্যাঙ্গুয়েজ মডেলের জন্য, আমি OpenAI (opens in a new tab) দিয়ে শুরু করার সিদ্ধান্ত নিয়েছি। এই টিউটোরিয়ালের অ্যাপ্লিকেশনটি চালানোর জন্য আপনাকে API অ্যাক্সেসের জন্য অর্থ প্রদান করতে হবে। ন্যূনতম $5 পেমেন্ট এর জন্য যথেষ্টর চেয়েও বেশি।

ডেভেলপমেন্ট, ধাপে ধাপে

ডেভেলপমেন্ট সহজ করার জন্য, আমরা ধাপে ধাপে এগিয়ে যাব। প্রতিটি ধাপ হলো GitHub-এর একটি ব্রাঞ্চ।

শুরু করা

UNIX বা Linux-এর (যার মধ্যে WSL (opens in a new tab) অন্তর্ভুক্ত) অধীনে শুরু করার জন্য কিছু ধাপ রয়েছে:

যদি আপনার কাছে আগে থেকে না থাকে, তবে Python (opens in a new tab) ডাউনলোড এবং ইনস্টল করুন।

GitHub রিপোজিটরি ক্লোন করুন।

1git clone https://github.com/qbzzt/260215-ai-agent.git -b 01-getting-started
2cd 260215-ai-agent

uv (opens in a new tab) ইনস্টল করুন। আপনার সিস্টেমে কমান্ডটি ভিন্ন হতে পারে।
```
1pipx install uv
```
লাইব্রেরিগুলো ডাউনলোড করুন।
```
1uv sync
```
ভার্চুয়াল এনভায়রনমেন্ট অ্যাক্টিভেট করুন।
```
1source .venv/bin/activate
```
Python এবং Web3 সঠিকভাবে কাজ করছে কিনা তা যাচাই করতে, python3 রান করুন এবং এতে এই প্রোগ্রামটি দিন। আপনি এটি >>> প্রম্পটে লিখতে পারেন; কোনো ফাইল তৈরি করার প্রয়োজন নেই।
```
1from web3 import Web3
2MAINNET_URL = "https://eth.drpc.org"
3w3 = Web3(Web3.HTTPProvider(MAINNET_URL))
4w3.eth.block_number
5quit()
```

ব্লকচেইন থেকে পড়া

পরবর্তী ধাপ হলো ব্লকচেইন থেকে পড়া। এটি করার জন্য, আপনাকে 02-read-quote ব্রাঞ্চে যেতে হবে এবং তারপর প্রোগ্রামটি রান করতে uv ব্যবহার করতে হবে।

1git checkout 02-read-quote
2uv run agent.py

আপনি Quote অবজেক্টের একটি তালিকা পাবেন, যার প্রতিটিতে একটি টাইমস্ট্যাম্প, একটি দাম এবং অ্যাসেট (বর্তমানে সর্বদা WETH/USDC) থাকবে।

এখানে লাইন-বাই-লাইন ব্যাখ্যা দেওয়া হলো।

1from web3 import Web3
2from web3.contract import Contract
3from decimal import Decimal, ROUND_HALF_UP
4from dataclasses import dataclass
5from datetime import datetime, timezone
6from pprint import pprint
7import time
8import functools
9import sys

আমাদের প্রয়োজনীয় লাইব্রেরিগুলো ইমপোর্ট করুন। এগুলো যখন ব্যবহার করা হবে তখন নিচে ব্যাখ্যা করা হবে।

1print = functools.partial(print, flush=True)

Python-এর print-কে এমন একটি ভার্সন দিয়ে প্রতিস্থাপন করে যা সর্বদা আউটপুট সাথে সাথে ফ্লাশ করে। এটি একটি দীর্ঘ সময় ধরে চলা স্ক্রিপ্টে দরকারী কারণ আমরা স্ট্যাটাস আপডেট বা ডিবাগিং আউটপুটের জন্য অপেক্ষা করতে চাই না।

1MAINNET_URL = "https://eth.drpc.org"

মেইননেট-এ যাওয়ার জন্য একটি URL। আপনি নোড অ্যাজ এ সার্ভিস থেকে একটি পেতে পারেন অথবা Chainlist (opens in a new tab)-এ বিজ্ঞাপিত যেকোনো একটি ব্যবহার করতে পারেন।

1BLOCK_TIME_SECONDS = 12
2MINUTE_BLOCKS = int(60 / BLOCK_TIME_SECONDS)
3HOUR_BLOCKS = MINUTE_BLOCKS * 60
4DAY_BLOCKS = HOUR_BLOCKS * 24

একটি ইথিরিয়াম মেইননেট ব্লক সাধারণত প্রতি বারো সেকেন্ডে তৈরি হয়, তাই একটি নির্দিষ্ট সময়ের মধ্যে আমরা এই সংখ্যক ব্লক আশা করতে পারি। মনে রাখবেন যে এটি কোনো সঠিক সংখ্যা নয়। যখন ব্লক প্রপোজার ডাউন থাকে, তখন সেই ব্লকটি বাদ দেওয়া হয় এবং পরবর্তী ব্লকের জন্য সময় হয় 24 সেকেন্ড। আমরা যদি একটি টাইমস্ট্যাম্পের জন্য সঠিক ব্লকটি পেতে চাই, তবে আমরা বাইনারি সার্চ (opens in a new tab) ব্যবহার করব। তবে, আমাদের উদ্দেশ্যের জন্য এটি যথেষ্ট কাছাকাছি। ভবিষ্যৎবাণী করা কোনো নিখুঁত বিজ্ঞান নয়।

1CYCLE_BLOCKS = DAY_BLOCKS

সাইকেলের আকার। আমরা প্রতি সাইকেলে একবার কোটগুলো পর্যালোচনা করি এবং পরবর্তী সাইকেলের শেষে মান অনুমান করার চেষ্টা করি।

1# আমরা যে পুলটি পড়ছি তার ঠিকানা
2WETHUSDC_ADDRESS = Web3.to_checksum_address("0x88e6A0c2dDD26FEEb64F039a2c41296FcB3f5640")

কোটের মানগুলো এডড্রেস 0x88e6A0c2dDD26FEEb64F039a2c41296FcB3f5640 (opens in a new tab)-এ থাকা Uniswap 3 USDC/WETH পুল থেকে নেওয়া হয়েছে। এই এডড্রেসটি আগে থেকেই চেকসাম ফর্মে আছে, তবে কোডটি পুনরায় ব্যবহারযোগ্য করার জন্য Web3.to_checksum_address (opens in a new tab) ব্যবহার করা ভালো।

1POOL_ABI = [
2    { "name": "slot0", ... },
3    { "name": "token0", ... },
4    { "name": "token1", ... },
5]
6
7ERC20_ABI = [
8    { "name": "symbol", ... },
9    { "name": "decimals", ... }
10]

এগুলো হলো সেই দুটি কন্ট্রাক্টের ABIs (opens in a new tab) যাদের সাথে আমাদের যোগাযোগ করতে হবে। কোডটি সংক্ষিপ্ত রাখার জন্য, আমরা কেবল সেই ফাংশনগুলো অন্তর্ভুক্ত করেছি যেগুলো আমাদের কল করতে হবে।

1w3 = Web3(Web3.HTTPProvider(MAINNET_URL))

Web3 (opens in a new tab) লাইব্রেরি ইনিশিয়েট করুন এবং একটি ইথিরিয়াম নোড-এর সাথে কানেক্ট করুন।

1@dataclass(frozen=True)
2class ERC20Token:
3    address: str
4    symbol: str
5    decimals: int
6    contract: Contract

Python-এ ডেটা ক্লাস তৈরি করার এটি একটি উপায়। কন্ট্রাক্টের সাথে কানেক্ট করার জন্য Contract (opens in a new tab) ডেটা টাইপ ব্যবহার করা হয়। (frozen=True) লক্ষ্য করুন। Python-এ বুলিয়ানগুলো (opens in a new tab) True বা False হিসেবে সংজ্ঞায়িত করা হয়, যার প্রথম অক্ষর বড় হাতের হয়। এই ডেটা ক্লাসটি frozen, যার মানে এর ফিল্ডগুলো পরিবর্তন করা যাবে না।

ইনডেন্টেশন লক্ষ্য করুন। C-ভিত্তিক ভাষাগুলোর (opens in a new tab) বিপরীতে, Python ব্লক বোঝাতে ইনডেন্টেশন ব্যবহার করে। Python ইন্টারপ্রেটার জানে যে পরবর্তী সংজ্ঞাটি এই ডেটা ক্লাসের অংশ নয় কারণ এটি ডেটা ক্লাসের ফিল্ডগুলোর মতো একই ইনডেন্টেশনে শুরু হয়নি।

1@dataclass(frozen=True)
2class PoolInfo:
3    address: str
4    token0: ERC20Token
5    token1: ERC20Token
6    contract: Contract
7    asset: str
8    decimal_factor: Decimal = 1

দশমিক ভগ্নাংশগুলো সঠিকভাবে পরিচালনা করার জন্য Decimal (opens in a new tab) টাইপ ব্যবহার করা হয়।

1    def get_price(self, block: int) -> Decimal:

Python-এ একটি ফাংশন সংজ্ঞায়িত করার এটিই উপায়। সংজ্ঞাটি ইনডেন্ট করা হয়েছে যাতে বোঝা যায় এটি এখনও PoolInfo-এর অংশ।

একটি ডেটা ক্লাসের অংশ এমন একটি ফাংশনে প্রথম প্যারামিটারটি সর্বদা self হয়, যা ডেটা ক্লাসের ইনস্ট্যান্স যা এখানে কল করেছে। এখানে আরেকটি প্যারামিটার রয়েছে, ব্লক নম্বর।

1        assert block <= w3.eth.block_number, "Block is in the future"

আমরা যদি ভবিষ্যৎ পড়তে পারতাম, তবে ট্রেডিংয়ের জন্য আমাদের AI-এর প্রয়োজন হতো না।

1        sqrt_price_x96 = Decimal(self.contract.functions.slot0().call(block_identifier=block)[0])

Web3 থেকে ইথিরিয়াম ভার্চুয়াল মেশিন-এ একটি ফাংশন কল করার সিনট্যাক্স হলো: <contract object>.functions.<function name>().call(<parameters>)। প্যারামিটারগুলো ইথিরিয়াম ভার্চুয়াল মেশিন ফাংশনের প্যারামিটার হতে পারে (যদি থাকে; এখানে নেই) অথবা ব্লকচেইন আচরণ পরিবর্তন করার জন্য নেমড প্যারামিটার (opens in a new tab) হতে পারে। এখানে আমরা একটি ব্যবহার করেছি, block_identifier, যা দিয়ে আমরা যে ব্লক নম্বর-এ রান করতে চাই তা নির্দিষ্ট করি।

ফলাফল হলো এই স্ট্রাক্ট, অ্যারে ফর্মে (opens in a new tab)। প্রথম মানটি হলো দুটি টোকেন-এর মধ্যে এক্সচেঞ্জ রেটের একটি ফাংশন।

1        raw_price = (sqrt_price_x96 / Decimal(2**96)) ** 2

অনচেইন হিসাব কমানোর জন্য, Uniswap v3 প্রকৃত এক্সচেঞ্জ ফ্যাক্টর সংরক্ষণ করে না বরং এর বর্গমূল সংরক্ষণ করে। যেহেতু ইথিরিয়াম ভার্চুয়াল মেশিন ফ্লোটিং পয়েন্ট গণিত বা ভগ্নাংশ সমর্থন করে না, তাই প্রকৃত মানের পরিবর্তে, রেসপন্স হলো $\sqrt{price} \cdot 2^{96}$

1         # (প্রতি token0-এর জন্য token1)
2        return 1/(raw_price * self.decimal_factor)

আমরা যে র (raw) দাম পাই তা হলো প্রতিটি token1-এর জন্য আমরা কতগুলো token0 পাই। আমাদের পুলে token0 হলো USDC (স্টেবলকয়েন যার মান একটি ইউএস ডলারের সমান) এবং token1 হলো WETH (opens in a new tab)। আমরা আসলে যে মানটি চাই তা হলো প্রতি WETH-এর জন্য ডলারের সংখ্যা, এর বিপরীতটি নয়।

ডেসিমাল ফ্যাক্টর হলো দুটি টোকেন-এর ডেসিমাল ফ্যাক্টরগুলোর (opens in a new tab) মধ্যকার অনুপাত।

1@dataclass(frozen=True)
2class Quote:
3    timestamp: str
4    price: Decimal
5    asset: str

এই ডেটা ক্লাসটি একটি কোট উপস্থাপন করে: একটি নির্দিষ্ট সময়ে একটি নির্দিষ্ট অ্যাসেটের দাম। এই মুহূর্তে, asset ফিল্ডটি অপ্রাসঙ্গিক কারণ আমরা একটি একক পুল ব্যবহার করি এবং তাই আমাদের একটি একক অ্যাসেট রয়েছে। তবে, আমরা পরে আরও অ্যাসেট যোগ করব।

1def read_token(address: str) -> ERC20Token:
2    token = w3.eth.contract(address=address, abi=ERC20_ABI)
3    symbol = token.functions.symbol().call()
4    decimals = token.functions.decimals().call()
5
6    return ERC20Token(
7        address=address,
8        symbol=symbol,
9        decimals=decimals,
10        contract=token
11    )

এই ফাংশনটি একটি এডড্রেস নেয় এবং সেই এডড্রেস-এ থাকা টোকেন কন্ট্রাক্ট সম্পর্কে তথ্য ফেরত দেয়। একটি নতুন Web3 Contract (opens in a new tab) তৈরি করতে, আমরা w3.eth.contract-এ এডড্রেস এবং ABI প্রদান করি।

1def read_pool(address: str) -> PoolInfo:
2    pool_contract = w3.eth.contract(address=address, abi=POOL_ABI)
3    token0Address = pool_contract.functions.token0().call()
4    token1Address = pool_contract.functions.token1().call()
5    token0 = read_token(token0Address)
6    token1 = read_token(token1Address)
7
8    return PoolInfo(
9        address=address,
10        asset=f"{token1.symbol}/{token0.symbol}",
11        token0=token0,
12        token1=token1,
13        contract=pool_contract,
14        decimal_factor=Decimal(10) ** Decimal(token0.decimals - token1.decimals)
15    )

এই ফাংশনটি একটি নির্দিষ্ট পুল (opens in a new tab) সম্পর্কে আমাদের প্রয়োজনীয় সবকিছু ফেরত দেয়। f"<string>" সিনট্যাক্সটি হলো একটি ফরম্যাটেড স্ট্রিং (opens in a new tab)।

1def get_quote(pool: PoolInfo, block_number: int = None) -> Quote:

একটি Quote অবজেক্ট পান। block_number-এর ডিফল্ট মান হলো None (কোনো মান নেই)।

1    if block_number is None:
2        block_number = w3.eth.block_number

যদি কোনো ব্লক নম্বর নির্দিষ্ট করা না থাকে, তবে w3.eth.block_number ব্যবহার করুন, যা হলো সর্বশেষ ব্লক নম্বর। এটি একটি if স্টেটমেন্টের (opens in a new tab) সিনট্যাক্স।

এটি দেখে মনে হতে পারে যে ডিফল্ট হিসেবে শুধু w3.eth.block_number সেট করা ভালো হতো, কিন্তু এটি ভালোভাবে কাজ করে না কারণ এটি ফাংশনটি সংজ্ঞায়িত করার সময়ের ব্লক নম্বর হবে। একটি দীর্ঘ সময় ধরে চলা এজেন্টে, এটি একটি সমস্যা হবে।

1    block = w3.eth.get_block(block_number)
2    price = pool.get_price(block_number)
3    return Quote(
4        timestamp=datetime.fromtimestamp(block.timestamp, timezone.utc).isoformat(),
5        price=price.quantize(Decimal("0.01")),
6        asset=pool.asset
7    )

মানুষ এবং লার্জ ল্যাঙ্গুয়েজ মডেলগুলোর (LLMs) পড়ার উপযোগী একটি ফরম্যাটে এটি ফরম্যাট করতে datetime লাইব্রেরি (opens in a new tab) ব্যবহার করুন। মানটিকে দুই দশমিক স্থান পর্যন্ত রাউন্ড করতে Decimal.quantize (opens in a new tab) ব্যবহার করুন।

1def get_quotes(pool: PoolInfo, start_block: int, end_block: int, step: int) -> list[Quote]:

Python-এ আপনি list[<type>] ব্যবহার করে এমন একটি লিস্ট (opens in a new tab) সংজ্ঞায়িত করতে পারেন যা কেবল একটি নির্দিষ্ট টাইপ ধারণ করতে পারে।

1    quotes = []
2    for block in range(start_block, end_block + 1, step):

Python-এ একটি for লুপ (opens in a new tab) সাধারণত একটি লিস্টের উপর ইটারেট করে। কোটগুলো খোঁজার জন্য ব্লক নম্বরগুলোর লিস্ট range (opens in a new tab) থেকে আসে।

1        quote = get_quote(pool, block)
2        quotes.append(quote)
3    return quotes

প্রতিটি ব্লক নম্বরের জন্য, একটি Quote অবজেক্ট পান এবং এটি quotes লিস্টে যুক্ত করুন। তারপর সেই লিস্টটি ফেরত দিন।

1pool = read_pool(WETHUSDC_ADDRESS)
2quotes = get_quotes(
3    pool,
4    w3.eth.block_number - 12*CYCLE_BLOCKS,
5    w3.eth.block_number,
6    CYCLE_BLOCKS
7)
8
9pprint(quotes)

এটি স্ক্রিপ্টের মূল কোড। পুলের তথ্য পড়ুন, বারোটি কোট পান এবং সেগুলোকে pprint (opens in a new tab) করুন।

একটি প্রম্পট তৈরি করা

এরপর, আমাদের কোটগুলোর এই লিস্টটিকে একটি LLM-এর জন্য প্রম্পটে রূপান্তর করতে হবে এবং একটি প্রত্যাশিত ভবিষ্যৎ মান পেতে হবে।

1git checkout 03-create-prompt
2uv run agent.py

আউটপুটটি এখন একটি LLM-এর জন্য প্রম্পট হতে যাচ্ছে, যা অনেকটা এরকম:

1Given these quotes:
2Asset: WETH/USDC
3        2026-01-20T16:34 3016.21
4        .
5        .
6        .
7        2026-02-01T17:49 2299.10
8
9Asset: WBTC/WETH
10        2026-01-20T16:34 29.84
11        .
12        .
13        .
14        2026-02-01T17:50 33.46
15
16
17What would you expect the value for WETH/USDC to be at time 2026-02-02T17:56?
18
19Provide your answer as a single number rounded to two decimal places,
20without any other text.

লক্ষ্য করুন যে এখানে দুটি অ্যাসেটের কোট রয়েছে, WETH/USDC এবং WBTC/WETH। অন্য একটি অ্যাসেট থেকে কোট যোগ করলে প্রেডিকশনের নির্ভুলতা উন্নত হতে পারে।

একটি প্রম্পট দেখতে কেমন হয়

এই প্রম্পটে তিনটি বিভাগ রয়েছে, যা LLM প্রম্পটগুলোতে বেশ সাধারণ।

তথ্য। LLM-গুলোর কাছে তাদের ট্রেনিং থেকে অনেক তথ্য থাকে, কিন্তু সাধারণত তাদের কাছে সর্বশেষ তথ্য থাকে না। এই কারণেই আমাদের এখানে সর্বশেষ কোটগুলো পুনরুদ্ধার করতে হবে। একটি প্রম্পটে তথ্য যোগ করাকে রিট্রিভাল অগমেন্টেড জেনারেশন (RAG) (opens in a new tab) বলা হয়।
আসল প্রশ্ন। এটিই আমরা জানতে চাই।
আউটপুট ফরম্যাটিং নির্দেশাবলী। সাধারণত, একটি LLM আমাদের একটি অনুমান দেবে এবং এটি কীভাবে সেখানে পৌঁছাল তার একটি ব্যাখ্যা দেবে। এটি মানুষের জন্য ভালো, কিন্তু একটি কম্পিউটার প্রোগ্রামের কেবল মূল ফলাফলটি প্রয়োজন।

কোড ব্যাখ্যা

এখানে নতুন কোড দেওয়া হলো।

1from datetime import datetime, timezone, timedelta

আমাদের LLM-কে সেই সময়টি প্রদান করতে হবে যার জন্য আমরা একটি অনুমান চাই। ভবিষ্যতে "n মিনিট/ঘণ্টা/দিন" সময় পেতে, আমরা timedelta ক্লাস (opens in a new tab) ব্যবহার করি।

1# আমরা যে পুলগুলো পড়ছি সেগুলোর ঠিকানা
2WETHUSDC_ADDRESS = Web3.to_checksum_address("0x88e6A0c2dDD26FEEb64F039a2c41296FcB3f5640")
3WETHWBTC_ADDRESS = Web3.to_checksum_address("0xCBCdF9626bC03E24f779434178A73a0B4bad62eD")

আমাদের দুটি পুল রয়েছে যা আমাদের পড়তে হবে।

1@dataclass(frozen=True)
2class PoolInfo:
3    .
4    .
5    .
6    reverse: bool = False
7
8    def get_price(self, block: int) -> Decimal:
9        assert block <= w3.eth.block_number, "Block is in the future"
10        sqrt_price_x96 = Decimal(self.contract.functions.slot0().call(block_identifier=block)[0])
11        raw_price = (sqrt_price_x96 / Decimal(2**96)) ** 2 # (প্রতি token0-এর জন্য token1)
12        if self.reverse:
13            return 1/(raw_price * self.decimal_factor)
14        else:
15            return raw_price * self.decimal_factor

WETH/USDC পুলে, আমরা জানতে চাই একটি token1 (WETH) কিনতে আমাদের কতগুলো token0 (USDC) প্রয়োজন। WETH/WBTC পুলে, আমরা জানতে চাই একটি token0 (WBTC, যা হলো র‍্যাপড বিটকয়েন) কিনতে আমাদের কতগুলো token1 (WETH) প্রয়োজন। পুলের অনুপাতটি উল্টানো দরকার কিনা তা আমাদের ট্র্যাক করতে হবে।

1def read_pool(address: str, reverse: bool = False) -> PoolInfo:
2    .
3    .
4    .
5
6    return PoolInfo(
7        .
8        .
9        .
10
11        asset= f"{token1.symbol}/{token0.symbol}" if reverse else f"{token0.symbol}/{token1.symbol}",
12        reverse=reverse
13    )

একটি পুল উল্টানো দরকার কিনা তা জানতে, আমরা সেটিকে read_pool-এর ইনপুট হিসেবে পাই। এছাড়াও, অ্যাসেট সিম্বলটি সঠিকভাবে সেট আপ করতে হবে।

<a> if <b> else <c> সিনট্যাক্সটি হলো টার্নারি কন্ডিশনাল অপারেটরের (opens in a new tab) Python সমতুল্য, যা একটি C-ভিত্তিক ভাষায় <b> ? <a> : <c> হবে।

1def format_quotes(quotes: list[Quote]) -> str:
2    result = f"Asset: {quotes[0].asset}\n"
3    for quote in quotes:
4        result += f"\t{quote.timestamp[0:16]} {quote.price.quantize(Decimal('0.01'), rounding=ROUND_HALF_UP)}\n"
5    return result

এই ফাংশনটি এমন একটি স্ট্রিং তৈরি করে যা Quote অবজেক্টের একটি লিস্ট ফরম্যাট করে, ধরে নেওয়া হয় যে সেগুলো সবই একই অ্যাসেটের ক্ষেত্রে প্রযোজ্য।

1def make_prompt(quotes: list[list[Quote]], expected_time: str, asset: str) -> str:
2    return f"""

Python-এ মাল্টি-লাইন স্ট্রিং লিটারেলগুলো (opens in a new tab) """ .... """ হিসেবে লেখা হয়।

1Given these quotes:
2{
3    functools.reduce(lambda acc, q: acc + '\n' + q,
4        map(lambda q: format_quotes(q), quotes))
5}

এখানে, আমরা format_quotes দিয়ে প্রতিটি কোট লিস্টের জন্য একটি স্ট্রিং তৈরি করতে MapReduce (opens in a new tab) প্যাটার্ন ব্যবহার করি, তারপর প্রম্পটে ব্যবহারের জন্য সেগুলোকে একটি একক স্ট্রিংয়ে রিডিউস করি।

1What would you expect the value for {asset} to be at time {expected_time}?
2
3Provide your answer as a single number rounded to two decimal places,
4without any other text.
5    """

প্রম্পটের বাকি অংশ প্রত্যাশিত মতোই।

1wethusdc_pool = read_pool(WETHUSDC_ADDRESS, True)
2wethusdc_quotes = get_quotes(
3    wethusdc_pool,
4    w3.eth.block_number - 12*CYCLE_BLOCKS,
5    w3.eth.block_number,
6    CYCLE_BLOCKS,
7)
8
9wethwbtc_pool = read_pool(WETHWBTC_ADDRESS)
10wethwbtc_quotes = get_quotes(
11    wethwbtc_pool,
12    w3.eth.block_number - 12*CYCLE_BLOCKS,
13    w3.eth.block_number,
14    CYCLE_BLOCKS
15)

দুটি পুল পর্যালোচনা করুন এবং উভয়টি থেকে কোট সংগ্রহ করুন।

1future_time = (datetime.now(timezone.utc) + timedelta(days=1)).isoformat()[0:16]
2
3print(make_prompt(wethusdc_quotes + wethwbtc_quotes, future_time, wethusdc_pool.asset))

ভবিষ্যতের সেই সময় বিন্দুটি নির্ধারণ করুন যার জন্য আমরা অনুমান চাই এবং প্রম্পটটি তৈরি করুন।

একটি LLM-এর সাথে ইন্টারফেসিং

এরপর, আমরা একটি আসল LLM-কে প্রম্পট করি এবং একটি প্রত্যাশিত ভবিষ্যৎ মান গ্রহণ করি। আমি OpenAI ব্যবহার করে এই প্রোগ্রামটি লিখেছি, তাই আপনি যদি অন্য কোনো প্রোভাইডার ব্যবহার করতে চান, তবে আপনাকে এটি সামঞ্জস্য করতে হবে।

একটি OpenAI একাউন্ট (opens in a new tab) পান
একাউন্টে ফান্ড যোগ করুন (opens in a new tab)—লেখার সময় ন্যূনতম পরিমাণ হলো $5
একটি API কি তৈরি করুন (opens in a new tab)
কমান্ড লাইনে, API কি এক্সপোর্ট করুন যাতে আপনার প্রোগ্রাম এটি ব্যবহার করতে পারে
```
1export OPENAI_API_KEY=sk-<the rest of the key goes here>
```
চেকআউট করুন এবং এজেন্ট রান করুন
```
1git checkout 04-interface-llm
2uv run agent.py
```

এখানে নতুন কোড দেওয়া হলো।

1from openai import OpenAI
2
3open_ai = OpenAI() # ক্লায়েন্ট OPENAI_API_KEY এনভায়রনমেন্ট ভেরিয়েবলটি পড়ে

OpenAI API ইমপোর্ট এবং ইনস্ট্যানশিয়েট করুন।

1response = open_ai.chat.completions.create(
2    model="gpt-4-turbo",
3    messages=[
4        {"role": "user", "content": prompt}
5    ],
6    temperature=0.0,
7    max_tokens=16,
8)

রেসপন্স তৈরি করতে OpenAI API (open_ai.chat.completions.create) কল করুন।

1expected_price = Decimal(response.choices[0].message.content.strip())
2current_price = wethusdc_quotes[-1].price
3
4print ("Current price:", wethusdc_quotes[-1].price)
5print(f"In {future_time}, expected price: {expected_price} USD")
6
7if (expected_price > current_price):
8    print(f"Buy, I expect the price to go up by {expected_price - current_price} USD")
9else:
10    print(f"Sell, I expect the price to go down by {current_price - expected_price} USD")

দাম আউটপুট করুন এবং একটি ক্রয় বা বিক্রয়ের সুপারিশ প্রদান করুন।

প্রেডিকশনগুলো পরীক্ষা করা

যেহেতু এখন আমরা প্রেডিকশন তৈরি করতে পারি, তাই আমরা দরকারী প্রেডিকশন তৈরি করছি কিনা তা মূল্যায়ন করতে ঐতিহাসিক ডেটাও ব্যবহার করতে পারি।

1uv run test-predictor.py

প্রত্যাশিত ফলাফল অনেকটা এরকম:

1Prediction for 2026-01-05T19:50: predicted 3138.93 USD, real 3218.92 USD, error 79.99 USD
2Prediction for 2026-01-06T19:56: predicted 3243.39 USD, real 3221.08 USD, error 22.31 USD
3Prediction for 2026-01-07T20:02: predicted 3223.24 USD, real 3146.89 USD, error 76.35 USD
4Prediction for 2026-01-08T20:11: predicted 3150.47 USD, real 3092.04 USD, error 58.43 USD
5.
6.
7.
8Prediction for 2026-01-31T22:33: predicted 2637.73 USD, real 2417.77 USD, error 219.96 USD
9Prediction for 2026-02-01T22:41: predicted 2381.70 USD, real 2318.84 USD, error 62.86 USD
10Prediction for 2026-02-02T22:49: predicted 2234.91 USD, real 2349.28 USD, error 114.37 USD
11Mean prediction error over 29 predictions: 83.87103448275862068965517241 USD
12Mean change per recommendation: 4.787931034482758620689655172 USD
13Standard variance of changes: 104.42 USD
14Profitable days: 51.72%
15Losing days: 48.28%

টেস্টারের বেশিরভাগ অংশই এজেন্টের মতো একই, তবে এখানে নতুন বা পরিবর্তিত অংশগুলো দেওয়া হলো।

1CYCLES_FOR_TEST = 40 # ব্যাকটেস্টের জন্য, আমরা কতগুলো সাইকেল ধরে টেস্ট করি
2
3# প্রচুর কোট সংগ্রহ করুন
4wethusdc_pool = read_pool(WETHUSDC_ADDRESS, True)
5wethusdc_quotes = get_quotes(
6    wethusdc_pool,
7    w3.eth.block_number - CYCLE_BLOCKS*CYCLES_FOR_TEST,
8    w3.eth.block_number,
9    CYCLE_BLOCKS,
10)
11
12wethwbtc_pool = read_pool(WETHWBTC_ADDRESS)
13wethwbtc_quotes = get_quotes(
14    wethwbtc_pool,
15    w3.eth.block_number - CYCLE_BLOCKS*CYCLES_FOR_TEST,
16    w3.eth.block_number,
17    CYCLE_BLOCKS
18)

আমরা CYCLES_FOR_TEST (এখানে 40 হিসেবে নির্দিষ্ট করা হয়েছে) দিন পিছনের দিকে তাকাই।

1# পূর্বাভাস তৈরি করুন এবং প্রকৃত ইতিহাসের সাথে সেগুলো যাচাই করুন
2
3total_error = Decimal(0)
4changes = []

আমরা দুই ধরনের ত্রুটির প্রতি আগ্রহী। প্রথমটি, total_error, হলো প্রেডিক্টরের করা ত্রুটিগুলোর সাধারণ যোগফল।

দ্বিতীয়টি, changes, বোঝার জন্য আমাদের এজেন্টের উদ্দেশ্য মনে রাখতে হবে। এর উদ্দেশ্য WETH/USDC অনুপাত (ETH-এর দাম) প্রেডিক্ট করা নয়। এর উদ্দেশ্য হলো বিক্রয় এবং ক্রয়ের সুপারিশ জারি করা। যদি বর্তমানে দাম $2000 হয় এবং এটি আগামীকাল $2010 প্রেডিক্ট করে, তবে আসল ফলাফল $2020 হলে এবং আমরা অতিরিক্ত অর্থ উপার্জন করলে আমাদের কোনো আপত্তি নেই। কিন্তু আমরা অবশ্যই আপত্তি করব যদি এটি $2010 প্রেডিক্ট করে, এবং সেই সুপারিশের ভিত্তিতে ETH কেনে, এবং দাম $1990-এ নেমে যায়।

1for index in range(0,len(wethusdc_quotes)-CYCLES_BACK):

আমরা কেবল সেই ক্ষেত্রগুলো দেখতে পারি যেখানে সম্পূর্ণ ইতিহাস (প্রেডিকশনের জন্য ব্যবহৃত মানগুলো এবং এর সাথে তুলনা করার জন্য বাস্তব-বিশ্বের মান) উপলব্ধ। এর মানে হলো সবচেয়ে নতুন ক্ষেত্রটি অবশ্যই সেটি হতে হবে যা CYCLES_BACK আগে শুরু হয়েছিল।

1    wethusdc_slice = wethusdc_quotes[index:index+CYCLES_BACK]
2    wethwbtc_slice = wethwbtc_quotes[index:index+CYCLES_BACK]

এজেন্ট যে সংখ্যক স্যাম্পল ব্যবহার করে ঠিক সেই সংখ্যক স্যাম্পল পেতে স্লাইস (opens in a new tab) ব্যবহার করুন। এখান থেকে পরবর্তী সেগমেন্টের মধ্যবর্তী কোডটি এজেন্টে থাকা প্রেডিকশন পাওয়ার কোডের মতোই।

1    predicted_price = Decimal(response.choices[0].message.content.strip())
2    real_price = wethusdc_quotes[index+CYCLES_BACK].price
3    prediction_time_price = wethusdc_quotes[index+CYCLES_BACK-1].price

প্রেডিক্ট করা দাম, আসল দাম এবং প্রেডিকশনের সময়ের দাম পান। সুপারিশটি ক্রয় নাকি বিক্রয়ের ছিল তা নির্ধারণ করতে আমাদের প্রেডিকশনের সময়ের দাম প্রয়োজন।

1    error = abs(predicted_price - real_price)
2    total_error += error
3    print (f"Prediction for {prediction_time}: predicted {predicted_price} USD, real {real_price} USD, error {error} USD")

ত্রুটিটি বের করুন এবং এটি মোটের সাথে যোগ করুন।

1    recomended_action = 'buy' if predicted_price > prediction_time_price else 'sell'
2    price_increase = real_price - prediction_time_price
3    changes.append(price_increase if recomended_action == 'buy' else -price_increase)

changes-এর জন্য, আমরা একটি ETH কেনা বা বেচার আর্থিক প্রভাব চাই। তাই প্রথমে, আমাদের সুপারিশটি নির্ধারণ করতে হবে, তারপর আসল দাম কীভাবে পরিবর্তিত হয়েছে তা মূল্যায়ন করতে হবে এবং সুপারিশটি অর্থ উপার্জন করেছে (ইতিবাচক পরিবর্তন) নাকি অর্থ ব্যয় করেছে (নেতিবাচক পরিবর্তন) তা দেখতে হবে।

1print (f"Mean prediction error over {len(wethusdc_quotes)-CYCLES_BACK} predictions: {total_error / Decimal(len(wethusdc_quotes)-CYCLES_BACK)} USD")
2
3length_changes = Decimal(len(changes))
4mean_change = sum(changes, Decimal(0)) / length_changes
5print (f"Mean change per recommendation: {mean_change} USD")
6var = sum((x - mean_change) ** 2 for x in changes) / length_changes
7print (f"Standard variance of changes: {var.sqrt().quantize(Decimal("0.01"))} USD")

ফলাফল রিপোর্ট করুন।

1print (f"Profitable days: {len(list(filter(lambda x: x > 0, changes)))/length_changes:.2%}")
2print (f"Losing days: {len(list(filter(lambda x: x < 0, changes)))/length_changes:.2%}")

লাভজনক দিনের সংখ্যা এবং ব্যয়বহুল দিনের সংখ্যা গণনা করতে filter (opens in a new tab) ব্যবহার করুন। ফলাফলটি একটি ফিল্টার অবজেক্ট, যার দৈর্ঘ্য পেতে আমাদের এটিকে একটি লিস্টে রূপান্তর করতে হবে।

লেনদেন জমা দেওয়া

এখন আমাদের আসলে লেনদেন জমা দিতে হবে। তবে, সিস্টেমটি প্রমাণিত হওয়ার আগে, আমি এই মুহূর্তে আসল অর্থ ব্যয় করতে চাই না। এর পরিবর্তে, আমরা মেইননেট-এর একটি লোকাল ফর্ক তৈরি করব এবং সেই নেটওয়ার্ক-এ "ট্রেড" করব।

একটি লোকাল ফর্ক তৈরি এবং ট্রেডিং সক্ষম করার ধাপগুলো নিচে দেওয়া হলো।

Foundry (opens in a new tab) ইনস্টল করুন
anvil (opens in a new tab) শুরু করুন
```
1anvil --fork-url https://eth.drpc.org --block-time 12
```
anvil Foundry-এর ডিফল্ট URL, http://localhost:8545-এ (opens in a new tab) শুনছে, তাই ব্লকচেইন ম্যানিপুলেট করার জন্য আমরা যে cast কমান্ড (opens in a new tab) ব্যবহার করি তার জন্য আমাদের URL নির্দিষ্ট করার প্রয়োজন নেই।
anvil-এ রান করার সময়, দশটি টেস্ট একাউন্ট থাকে যেগুলোতে ETH আছে—প্রথমটির জন্য এনভায়রনমেন্ট ভেরিয়েবলগুলো সেট করুন
```
1PRIVATE_KEY=0xac0974bec39a17e36ba4a6b4d238ff944bacb478cbed5efcae784d7bf4f2ff80
2ADDRESS=`cast wallet address $PRIVATE_KEY`
```
এগুলো হলো সেই কন্ট্রাক্টগুলো যা আমাদের ব্যবহার করতে হবে। SwapRouter (opens in a new tab) হলো সেই Uniswap v3 কন্ট্রাক্ট যা আমরা আসলে ট্রেড করার জন্য ব্যবহার করি। আমরা সরাসরি পুলের মাধ্যমে ট্রেড করতে পারতাম, কিন্তু এটি অনেক সহজ।

নিচের দুটি ভেরিয়েবল হলো WETH এবং USDC-এর মধ্যে সোয়াপ করার জন্য প্রয়োজনীয় Uniswap v3 পাথ।
```
1WETH_ADDRESS=0xC02aaA39b223FE8D0A0e5C4F27eAD9083C756Cc2
2USDC_ADDRESS=0xA0b86991c6218b36c1d19D4a2e9Eb0cE3606eB48
3POOL_ADDRESS=0x88e6A0c2dDD26FEEb64F039a2c41296FcB3f5640
4SWAP_ROUTER=0xE592427A0AEce92De3Edee1F18E0157C05861564
5WETH_TO_USDC=0xC02aaA39b223FE8D0A0e5C4F27eAD9083C756Cc20001F4A0b86991c6218b36c1d19D4a2e9Eb0cE3606eB48
6USDC_TO_WETH=0xA0b86991c6218b36c1d19D4a2e9Eb0cE3606eB480001F4C02aaA39b223FE8D0A0e5C4F27eAD9083C756Cc2
```
প্রতিটি টেস্ট একাউন্ট-এ 10,000 ETH রয়েছে। ট্রেডিংয়ের জন্য 1000 WETH পেতে 1000 ETH র‍্যাপ করতে WETH কন্ট্রাক্ট ব্যবহার করুন।
```
1cast send $WETH_ADDRESS "deposit()" --value 1000ether --private-key $PRIVATE_KEY
```
USDC-এর জন্য 500 WETH ট্রেড করতে SwapRouter ব্যবহার করুন।
```
1cast send $WETH_ADDRESS "approve(address,uint256)" $SWAP_ROUTER 500ether --private-key $PRIVATE_KEY
2MAXINT=`cast max-int uint256`
3cast send $SWAP_ROUTER \
4    "exactInput((bytes,address,uint256,uint256,uint256))" \
5    "($WETH_TO_USDC,$ADDRESS,$MAXINT,500ether,1000000)" \
6    --private-key $PRIVATE_KEY
```
approve কলটি একটি অ্যালাউন্স তৈরি করে যা SwapRouter-কে আমাদের কিছু টোকেন ব্যয় করার অনুমতি দেয়। কন্ট্রাক্টগুলো ইভেন্টগুলো মনিটর করতে পারে না, তাই আমরা যদি সরাসরি SwapRouter কন্ট্রাক্টে টোকেন ট্রান্সফার করি, তবে এটি জানতে পারবে না যে এটিকে পেমেন্ট করা হয়েছে। এর পরিবর্তে, আমরা SwapRouter কন্ট্রাক্টকে একটি নির্দিষ্ট পরিমাণ ব্যয় করার অনুমতি দিই, এবং তারপর SwapRouter সেটি করে। এটি SwapRouter দ্বারা কল করা একটি ফাংশনের মাধ্যমে করা হয়, তাই এটি জানতে পারে যে এটি সফল হয়েছে কিনা।
যাচাই করুন যে আপনার কাছে উভয় টোকেন-এর পর্যাপ্ত পরিমাণ রয়েছে।
```
1cast call $WETH_ADDRESS "balanceOf(address)" $ADDRESS | cast from-wei
2echo `cast call $USDC_ADDRESS "balanceOf(address)" $ADDRESS | cast to-dec`/10^6 | bc
```

যেহেতু এখন আমাদের কাছে WETH এবং USDC আছে, তাই আমরা আসলে এজেন্টটি রান করতে পারি।

1git checkout 05-trade
2uv run agent.py

আউটপুটটি অনেকটা এরকম দেখাবে:

1(ai-trading-agent) qbzzt@Ori-Cloudnomics:~/260215-ai-agent$ uv run agent.py
2Current price: 1843.16
3In 2026-02-06T23:07, expected price: 1724.41 USD
4Account balances before trade:
5USDC Balance: 927301.578272
6WETH Balance: 500
7Sell, I expect the price to go down by 118.75 USD
8Approve transaction sent: 74e367ddbb407c1aaf567d87aa5863049991b1d2aa092b6b85195d925e2bd41f
9Approve transaction mined.
10Sell transaction sent: fad1bcf938585c9e90364b26ac7a80eea9efd34c37e5db81e58d7655bcae28bf
11Sell transaction mined.
12Account balances after trade:
13USDC Balance: 929143.797116
14WETH Balance: 499

এটি আসলে ব্যবহার করার জন্য, আপনার কয়েকটি ছোট পরিবর্তনের প্রয়োজন।

লাইন 14-এ, MAINNET_URL-কে একটি আসল অ্যাক্সেস পয়েন্টে পরিবর্তন করুন, যেমন https://eth.drpc.org
লাইন 28-এ, PRIVATE_KEY-কে আপনার নিজস্ব প্রাইভেট কি-তে পরিবর্তন করুন
যদি না আপনি খুব ধনী হন এবং একটি অপ্রমাণিত এজেন্টের জন্য প্রতিদিন 1 ETH কিনতে বা বেচতে পারেন, তবে আপনি WETH_TRADE_AMOUNT কমানোর জন্য 29 পরিবর্তন করতে চাইতে পারেন

কোড ব্যাখ্যা

এখানে নতুন কোড দেওয়া হলো।

1SWAP_ROUTER_ADDRESS=Web3.to_checksum_address("0xE592427A0AEce92De3Edee1F18E0157C05861564")
2WETH_TO_USDC=bytes.fromhex("C02aaA39b223FE8D0A0e5C4F27eAD9083C756Cc20001F4A0b86991c6218b36c1d19D4a2e9Eb0cE3606eB48")
3USDC_TO_WETH=bytes.fromhex("A0b86991c6218b36c1d19D4a2e9Eb0cE3606eB480001F4C02aaA39b223FE8D0A0e5C4F27eAD9083C756Cc2")
4PRIVATE_KEY="0xac0974bec39a17e36ba4a6b4d238ff944bacb478cbed5efcae784d7bf4f2ff80"

ধাপ 4-এ আমরা যে ভেরিয়েবলগুলো ব্যবহার করেছি সেগুলোই।

1WETH_TRADE_AMOUNT=1

ট্রেড করার পরিমাণ।

1ERC20_ABI = [
2    { "name": "symbol", ... },
3    { "name": "decimals", ... },
4    { "name": "balanceOf", ...},
5    { "name": "approve", ...}
6]

আসলে ট্রেড করার জন্য, আমাদের approve ফাংশন প্রয়োজন। আমরা আগে এবং পরের ব্যালেন্সও দেখাতে চাই, তাই আমাদের balanceOf-ও প্রয়োজন।

1SWAP_ROUTER_ABI = [
2  { "name": "exactInput", ...},
3]

SwapRouter ABI-তে আমাদের শুধু exactInput প্রয়োজন। একটি সম্পর্কিত ফাংশন রয়েছে, exactOutput, যা আমরা ঠিক একটি WETH কেনার জন্য ব্যবহার করতে পারতাম, কিন্তু সরলতার জন্য আমরা উভয় ক্ষেত্রেই শুধু exactInput ব্যবহার করি।

1account = w3.eth.account.from_key(PRIVATE_KEY)
2swap_router = w3.eth.contract(
3    address=SWAP_ROUTER_ADDRESS,
4    abi=SWAP_ROUTER_ABI
5)

account (opens in a new tab) এবং SwapRouter কন্ট্রাক্টের জন্য Web3 সংজ্ঞাগুলো।

1def txn_params() -> dict:
2    return {
3        "from": account.address,
4        "value": 0,
5        "gas": 300000,
6        "nonce": w3.eth.get_transaction_count(account.address),
7    }

লেনদেন প্যারামিটারগুলো। আমাদের এখানে একটি ফাংশন প্রয়োজন কারণ নন্স (opens in a new tab) প্রতিবার পরিবর্তন হতে হবে।

1def approve_token(contract: Contract, amount: int):

SwapRouter-এর জন্য একটি টোকেন অ্যালাউন্স অনুমোদন করুন।

1    txn = contract.functions.approve(SWAP_ROUTER_ADDRESS, amount).build_transaction(txn_params())
2    signed_txn = w3.eth.account.sign_transaction(txn, private_key=PRIVATE_KEY)
3    tx_hash = w3.eth.send_raw_transaction(signed_txn.raw_transaction)

এভাবেই আমরা Web3-তে একটি লেনদেন পাঠাই। প্রথমে আমরা লেনদেন তৈরি করতে Contract অবজেক্ট (opens in a new tab) ব্যবহার করি। তারপর আমরা PRIVATE_KEY ব্যবহার করে লেনদেন সাইন করতে web3.eth.account.sign_transaction (opens in a new tab) ব্যবহার করি। সবশেষে, আমরা লেনদেন পাঠাতে w3.eth.send_raw_transaction (opens in a new tab) ব্যবহার করি।

1    print(f"Approve transaction sent: {tx_hash.hex()}")
2    w3.eth.wait_for_transaction_receipt(tx_hash)
3    print("Approve transaction mined.")

w3.eth.wait_for_transaction_receipt (opens in a new tab) লেনদেন মাইন হওয়া পর্যন্ত অপেক্ষা করে। প্রয়োজন হলে এটি রসিদ ফেরত দেয়।

1SELL_PARAMS = {
2    "path": WETH_TO_USDC,
3    "recipient": account.address,
4    "deadline": 2**256 - 1,
5    "amountIn": WETH_TRADE_AMOUNT * 10 ** wethusdc_pool.token1.decimals,
6    "amountOutMinimum": 0,
7}

WETH বিক্রি করার সময় এগুলো হলো প্যারামিটার।

1def make_buy_params(quote: Quote) -> dict:
2    return {
3        "path": USDC_TO_WETH,
4        "recipient": account.address,
5        "deadline": 2**256 - 1,
6        "amountIn": int(quote.price*WETH_TRADE_AMOUNT) * 10**wethusdc_pool.token0.decimals,
7        "amountOutMinimum": 0,
8    }

SELL_PARAMS-এর বিপরীতে, ক্রয়ের প্যারামিটারগুলো পরিবর্তন হতে পারে। ইনপুট পরিমাণ হলো 1 WETH-এর খরচ, যা quote-এ উপলব্ধ।

1def buy(quote: Quote):
2    buy_params = make_buy_params(quote)
3    approve_token(wethusdc_pool.token0.contract, buy_params["amountIn"])
4    txn = swap_router.functions.exactInput(buy_params).build_transaction(txn_params())
5    signed_txn = w3.eth.account.sign_transaction(txn, private_key=PRIVATE_KEY)
6    tx_hash = w3.eth.send_raw_transaction(signed_txn.raw_transaction)
7    print(f"Buy transaction sent: {tx_hash.hex()}")
8    w3.eth.wait_for_transaction_receipt(tx_hash)
9    print("Buy transaction mined.")
10
11
12def sell():
13    approve_token(wethusdc_pool.token1.contract,
14                  WETH_TRADE_AMOUNT * 10**wethusdc_pool.token1.decimals)
15    txn = swap_router.functions.exactInput(SELL_PARAMS).build_transaction(txn_params())
16    signed_txn = w3.eth.account.sign_transaction(txn, private_key=PRIVATE_KEY)
17    tx_hash = w3.eth.send_raw_transaction(signed_txn.raw_transaction)
18    print(f"Sell transaction sent: {tx_hash.hex()}")
19    w3.eth.wait_for_transaction_receipt(tx_hash)
20    print("Sell transaction mined.")

buy() এবং sell() ফাংশনগুলো প্রায় একই রকম। প্রথমে আমরা SwapRouter-এর জন্য পর্যাপ্ত অ্যালাউন্স অনুমোদন করি এবং তারপর আমরা সঠিক পাথ এবং পরিমাণ দিয়ে এটিকে কল করি।

1def balances():
2    token0_balance = wethusdc_pool.token0.contract.functions.balanceOf(account.address).call()
3    token1_balance = wethusdc_pool.token1.contract.functions.balanceOf(account.address).call()
4
5    print(f"{wethusdc_pool.token0.symbol} Balance: {Decimal(token0_balance) / Decimal(10 ** wethusdc_pool.token0.decimals)}")
6    print(f"{wethusdc_pool.token1.symbol} Balance: {Decimal(token1_balance) / Decimal(10 ** wethusdc_pool.token1.decimals)}")

উভয় কারেন্সিতে ব্যবহারকারীর ব্যালেন্স রিপোর্ট করুন।

1print("Account balances before trade:")
2balances()
3
4if (expected_price > current_price):
5    print(f"Buy, I expect the price to go up by {expected_price - current_price} USD")
6    buy(wethusdc_quotes[-1])
7else:
8    print(f"Sell, I expect the price to go down by {current_price - expected_price} USD")
9    sell()
10
11print("Account balances after trade:")
12balances()

এই এজেন্টটি বর্তমানে কেবল একবার কাজ করে। তবে, আপনি এটিকে ক্রমাগত কাজ করার জন্য পরিবর্তন করতে পারেন, হয় এটিকে crontab (opens in a new tab) থেকে রান করে অথবা 368-400 লাইনগুলোকে একটি লুপে র‍্যাপ করে এবং পরবর্তী সাইকেলের সময় না হওয়া পর্যন্ত অপেক্ষা করতে time.sleep (opens in a new tab) ব্যবহার করে।

সম্ভাব্য উন্নতিসমূহ

এটি কোনো সম্পূর্ণ প্রোডাকশন ভার্সন নয়; এটি কেবল বেসিক বিষয়গুলো শেখানোর একটি উদাহরণ। এখানে উন্নতির জন্য কিছু ধারণা দেওয়া হলো।

আরও স্মার্ট ট্রেডিং

কী করতে হবে তা সিদ্ধান্ত নেওয়ার সময় এজেন্ট দুটি গুরুত্বপূর্ণ বিষয় উপেক্ষা করে।

প্রত্যাশিত পরিবর্তনের মাত্রা। দাম কমার সম্ভাবনা থাকলে এজেন্ট একটি নির্দিষ্ট পরিমাণ WETH বিক্রি করে, কমার মাত্রা যাই হোক না কেন। যুক্তিযুক্তভাবে, ছোটখাটো পরিবর্তনগুলো উপেক্ষা করা এবং দাম কতটা কমবে বলে আমরা আশা করি তার উপর ভিত্তি করে বিক্রি করা ভালো হবে।
বর্তমান পোর্টফোলিও। যদি আপনার পোর্টফোলিওর 10% WETH-এ থাকে এবং আপনি মনে করেন যে দাম বাড়বে, তবে সম্ভবত আরও কেনা যৌক্তিক। কিন্তু যদি আপনার পোর্টফোলিওর 90% WETH-এ থাকে, তবে আপনি হয়তো যথেষ্ট এক্সপোজড, এবং আরও কেনার কোনো প্রয়োজন নেই। আপনি যদি দাম কমার আশা করেন তবে এর বিপরীতটি সত্য।

আপনি যদি আপনার ট্রেডিং কৌশল গোপন রাখতে চান তবে কী করবেন?

AI ভেন্ডররা তাদের LLM-গুলোতে আপনার পাঠানো কোয়েরিগুলো দেখতে পারে, যা আপনার এজেন্টের সাথে তৈরি করা আপনার জিনিয়াস ট্রেডিং সিস্টেমকে প্রকাশ করতে পারে। এমন একটি ট্রেডিং সিস্টেম যা খুব বেশি মানুষ ব্যবহার করে তা মূল্যহীন কারণ আপনি যখন কিনতে চান তখন খুব বেশি মানুষ কেনার চেষ্টা করে (এবং দাম বেড়ে যায়) এবং আপনি যখন বিক্রি করতে চান তখন বিক্রি করার চেষ্টা করে (এবং দাম কমে যায়)।

এই সমস্যা এড়াতে আপনি স্থানীয়ভাবে একটি LLM রান করতে পারেন, উদাহরণস্বরূপ, LM-Studio (opens in a new tab) ব্যবহার করে।

AI বট থেকে AI এজেন্ট

আপনি একটি ভালো যুক্তি দিতে পারেন যে এটি একটি AI বট, কোনো AI এজেন্ট নয়। এটি একটি অপেক্ষাকৃত সহজ কৌশল বাস্তবায়ন করে যা পূর্বনির্ধারিত তথ্যের উপর নির্ভর করে। আমরা সেলফ-ইমপ্রুভমেন্ট সক্ষম করতে পারি, উদাহরণস্বরূপ, Uniswap v3 পুলগুলোর একটি লিস্ট এবং তাদের সর্বশেষ মানগুলো প্রদান করে এবং জিজ্ঞাসা করে যে কোন কম্বিনেশনের সেরা প্রেডিক্টিভ ভ্যালু রয়েছে।

স্লিপেজ প্রোটেকশন

বর্তমানে কোনো স্লিপেজ প্রোটেকশন (opens in a new tab) নেই। যদি বর্তমান কোট $2000 হয় এবং প্রত্যাশিত দাম $2100 হয়, তবে এজেন্ট কিনবে। তবে, এজেন্ট কেনার আগে যদি খরচ বেড়ে $2200 হয়ে যায়, তবে আর কেনার কোনো মানে হয় না।

স্লিপেজ প্রোটেকশন বাস্তবায়ন করতে, agent.py (opens in a new tab)-এর 325 এবং 334 লাইনে একটি amountOutMinimum মান নির্দিষ্ট করুন।

উপসংহার

আশা করি, এখন আপনি AI এজেন্টগুলো নিয়ে শুরু করার জন্য যথেষ্ট জানেন। এটি এই বিষয়ের কোনো বিস্তৃত ওভারভিউ নয়; এর জন্য পুরো বই নিবেদিত রয়েছে, তবে এটি আপনাকে শুরু করার জন্য যথেষ্ট। শুভকামনা!

আমার আরও কাজের জন্য এখানে দেখুন (opens in a new tab)।

পেজ সর্বশেষ আপডেট: 3 মার্চ, 2026

ইথিরিয়ামে আপনার নিজস্ব AI ট্রেডিং এজেন্ট তৈরি করুন

এটি কেন করবেন?

টুলস

কেন Python?

ব্লকচেইন-এ ট্রেডিং

OpenAI

ডেভেলপমেন্ট, ধাপে ধাপে

শুরু করা

ব্লকচেইন থেকে পড়া

একটি প্রম্পট তৈরি করা

একটি প্রম্পট দেখতে কেমন হয়

কোড ব্যাখ্যা

একটি LLM-এর সাথে ইন্টারফেসিং

প্রেডিকশনগুলো পরীক্ষা করা

লেনদেন জমা দেওয়া

কোড ব্যাখ্যা

সম্ভাব্য উন্নতিসমূহ

আরও স্মার্ট ট্রেডিং

আপনি যদি আপনার ট্রেডিং কৌশল গোপন রাখতে চান তবে কী করবেন?

AI বট থেকে AI এজেন্ট

স্লিপেজ প্রোটেকশন

উপসংহার

এই টিউটোরিয়ালটি কি সহায়ক ছিল?