《区块链公链数据分析简易速速上手小册》第4章：交易数据分析（2024 最新版）（上）

pip install python-bitcoinrpc

from bitcoinrpc.authproxy import AuthServiceProxy, JSONRPCException
# 配置你的比特币节点RPC服务的访问信息
rpc_user = 'your_rpc_user'
rpc_password = 'your_rpc_password'
rpc_host = '127.0.0.1'
rpc_port = '8332'
# 创建RPC连接
rpc_connection = AuthServiceProxy(f"http://{rpc_user}:{rpc_password}@{rpc_host}:{rpc_port}/")
# 指定想要追踪的比特币交易ID
transaction_id = "your_transaction_id_here"
def get_transaction_details(txid):
    try:
        # 获取交易详情
        tx_details = rpc_connection.getrawtransaction(txid, True)
        print(f"Transaction Details for {txid}:")
        
        # 打印交易输入
        print("Inputs:")
        for vin in tx_details['vin']:
            input_txid = vin['txid']
            input_vout = vin['vout']
            input_tx = rpc_connection.getrawtransaction(input_txid, True)
            prev_out = input_tx['vout'][input_vout]
            print(f"  From: {prev_out['scriptPubKey']['addresses'][0]} Amount: {prev_out['value']} BTC")
        
        # 打印交易输出
        print("Outputs:")
        for vout in tx_details['vout']:
            amount = vout['value']
            addresses = vout['scriptPubKey']['addresses'][0] if 'addresses' in vout['scriptPubKey'] else 'Unknown'
            print(f"  To: {addresses} Amount: {amount} BTC")
    except JSONRPCException as e:
        print(e)
# 执行函数获取交易详情
get_transaction_details(transaction_id)

pip install web3

from web3 import Web3
# 使用Infura作为以太坊节点访问
infura_url = "https://mainnet.infura.io/v3/YOUR_INFURA_PROJECT_ID"
w3 = Web3(Web3.HTTPProvider(infura_url))
# 确认连接成功
assert w3.isConnected(), "Failed to connect to Ethereum network!"

# 指定要解析的交易哈希
tx_hash = "YOUR_TRANSACTION_HASH"
# 获取交易数据
transaction = w3.eth.get_transaction(tx_hash)

# 假设你已经有了智能合约的ABI和地址
contract_address = "YOUR_CONTRACT_ADDRESS"
contract_abi = "YOUR_CONTRACT_ABI"
# 创建智能合约对象
contract = w3.eth.contract(address=contract_address, abi=contract_abi)
# 解析交易输入
if transaction.to == contract_address:  # 确保交易是发往指定的合约
    try:
        tx_input = contract.decode_function_input(transaction.input)
        function_signature, args = tx_input
        print(f"Function called: {function_signature}")
        print(f"With arguments: {args}")
    except ValueError as e:
        print("Could not decode transaction input:", e)
else:
    print("Transaction is not to the specified contract.")

pip install web3 matplotlib networkx

from web3 import Web3
# 连接到以太坊网络（这里以Infura为例）
infura_url = "https://mainnet.infura.io/v3/YOUR_INFURA_PROJECT_ID"
w3 = Web3(Web3.HTTPProvider(infura_url))
# 确认连接成功
assert w3.isConnected(), "Failed to connect to Ethereum network!"
# 获取特定交易数据
tx_hash = "YOUR_TRANSACTION_HASH"
transaction = w3.eth.get_transaction(tx_hash)

import networkx as nx
# 创建有向图
G = nx.DiGraph()
# 添加交易流边
G.add_edge(transaction['from'], transaction['to'], weight=1)
# 如果有需要，你可以进一步分析交易，添加更多边

import matplotlib.pyplot as plt
# 设置图形布局
pos = nx.spring_layout(G)
# 绘制节点
nx.draw_networkx_nodes(G, pos, node_size=700)
# 绘制边
nx.draw_networkx_edges(G, pos, edgelist=G.edges(), edge_color='black')
# 绘制节点标签
nx.draw_networkx_labels(G, pos, font_size=12, font_family="sans-serif")
plt.axis("off")  # 关闭坐标轴
plt.show()  # 显示图形

pip install web3

from web3 import Web3
# 使用Infura连接到以太坊网络
w3 = Web3(Web3.HTTPProvider('https://mainnet.infura.io/v3/YOUR_INFURA_PROJECT_ID'))
# 确保连接成功
assert w3.isConnected(), "Failed to connect to Ethereum network!"

# 获取当前的平均Gas价格
current_gas_price = w3.eth.gas_price
print(f"Current Gas Price: {current_gas_price} wei")

# 简单ETH转账的标准Gas Limit
gas_limit = 21000

# 计算交易费用
transaction_fee = current_gas_price * gas_limit
# 将费用从wei转换为ETH
transaction_fee_eth = w3.fromWei(transaction_fee, 'ether')
print(f"Estimated Transaction Fee: {transaction_fee} wei ({transaction_fee_eth} ETH)")