Sure, here's an updated version of the code that includes a CoinbaseAdapter class with a fetch_and_store_pair method that takes a currency pair and table name as parameters:

```python 
import requests
import json
from sqlalchemy import create_engine, Column, Integer, Float, String
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import sessionmaker

Base = declarative_base()

class Trade(Base):
tablename = 'trades'
id = Column(Integer, primary_key=True)
price = Column(Float)
size = Column(Float)
time = Column(String)

class CoinbaseAdapter:
def init(self, db_uri):
self.db_uri = db_uri
self.engine = create_engine(self.db_uri)
self.Session = sessionmaker(bind=self.engine)

def fetch_and_store_pair(self, currency_pair, table_name):
    # Define the class that will map to the database table
    table_class = type(table_name, (Base,), {'__tablename__': table_name})

    # Define the Coinbase API URL and parameters
    url = f'https://api.coinbase.com/v2/trades/{currency_pair}'
    params = {'limit': 10}

    # Make a request to the Coinbase API and parse the JSON response
    response = requests.get(url, params=params)
    trades = json.loads(response.text)['data']

    # Create a new session and add the trades to the database
    session = self.Session()
    for trade in trades:
        new_trade = table_class(
            price=float(trade['price']),
            size=float(trade['size']),
            time=trade['time']
        )
        session.add(new_trade)
    session.commit()

    # Query the database and print the trades
    trades = session.query(table_class).all()
    for trade in trades:
        print(f"Trade: {trade.id}, Price: {trade.price}, Size: {trade.size}, Time: {trade.time}")
```

Example usage

```python
adapter = CoinbaseAdapter('sqlite:///coinbase.db')
adapter.fetch_and_store_pair('BTC-USD', 'btc_usd_trades')
```
แน่นอนว่า นี่คือโค้ดเวอร์ชันอัปเดตที่มีคลาส CoinbaseAdapter พร้อมเมธอด fetch_and_store_pair ที่ใช้คู่สกุลเงินและชื่อตารางเป็นพารามิเตอร์: ```คำขอนำเข้าหลาม นำเข้า json จาก sqlalchemy นำเข้า create_engine, คอลัมน์, จำนวนเต็ม, ลอย, สตริงจาก sqlalchemy.ext.declarative นำเข้า declarative_base จาก sqlalchemy.orm นำเข้า sessionmaker Base = declarative_base() class Trade(Base): tablename = 'trades' id = Column(Integer, primary_key=True) price = Column(Float) size = Column(Float ) เวลา = คอลัมน์ (สตริง) คลาส CoinbaseAdapter: def init(self, db_uri): self.db_uri = db_uri self.engine = create_engine(self.db_uri) self.Session = sessionmaker(bind=self.engine) def fetch_and_store_pair(self, currency_pair, table_name): # กำหนดคลาสที่จะแมปกับตารางฐานข้อมูล table_class = type(table_name, (Base,), {'__tablename__': table_name}) # กำหนด Coinbase API URL และพารามิเตอร์ url = f'https:/ /api.coinbase.com/v2/trades/{currency_pair}' params = {'limit': 10} # ส่งคำขอไปยัง Coinbase API และแยกวิเคราะห์การตอบสนอง JSON การตอบสนอง = request.get(url, params=params) การค้าขาย = json.loads(response.text)['data'] # สร้างเซสชันใหม่และเพิ่มการซื้อขายไปยังเซสชันฐานข้อมูล = self.Session() สำหรับการค้าขาย: new_trade = table_class( price=float(trade['price ']), size=float(trade['size']), time=trade['time'] ) session.add(new_trade) session.commit() # ค้นหาฐานข้อมูลและพิมพ์การซื้อขายการซื้อขาย = session.query( table_class).all() สำหรับการซื้อขาย: print(f"Trade: {trade.id}, Price: {trade.price}, Size: {trade.size}, Time: {trade.time}") `` ` ตัวอย่างการใช้งาน ```python adapter = CoinbaseAdapter('sqlite:///coinbase.db') adapter.fetch_and_store_pair('BTC-USD', 'btc_usd_trades') ```
spam fails_task lang_mismatch pii not_appropriate hate_speech sexual_content quality toxicity humor helpfulness creativity violence