使用 Web3.py 解码以太坊区块事件扫描后的数据-Python教程-PHP中文网

使用 Web3.py 解码以太坊区块事件扫描后的数据

花韻仙語

发布： 2025-10-30 12:31:14

原创

317人浏览过

使用 web3.py 解码以太坊区块事件扫描后的数据

本文旨在帮助开发者理解如何使用 Web3.py 扫描以太坊区块链上的事件，并解码事件数据。我们将深入探讨事件数据中包含的信息，以及如何将其转换为可读的格式，特别关注如何解析`data`字段中的十六进制数据，提取合约事件中存储的参数信息。

理解以太坊事件和数据结构

当智能合约执行 emit 语句时，会在区块链上记录一个事件。这些事件包含了合约的状态变化信息，可以被外部应用监听和处理。使用 Web3.py 扫描区块时，返回的事件对象通常包含一个 data 字段，该字段是一个十六进制字符串，包含了事件的具体参数。

data 字段的结构取决于事件的定义。通常，它包含事件中声明的各个参数的编码值。例如，如果事件包含一个地址和一个整数，那么 data 字段将包含这两个值的十六进制表示。

使用 Web3.py 扫描事件

以下代码展示了如何使用 Web3.py 扫描特定合约地址和区块范围内的事件：

from web3 import Web3

# 连接到以太坊节点
w3 = Web3(Web3.HTTPProvider('YOUR_ETHEREUM_NODE_URL'))

# 合约地址
contract_address = 'YOUR_CONTRACT_ADDRESS'

# 创建事件过滤器
event_filter = w3.eth.filter({
    'address': contract_address,
    'fromBlock': 4916476,
    'toBlock': 4916576
})

# 获取所有事件
for event in event_filter.get_all_entries():
    print(event)

登录后复制

这段代码会返回一个包含事件信息的字典，其中 data 字段是我们需要解码的部分。

解码事件数据

data 字段通常是十六进制编码的，需要根据事件的定义进行解码。假设我们有以下智能合约：

妙笔工坊

妙笔工坊是一个集短剧解说，AI视频生成，口播数字人，小说推文生成的ai智能工具

查看详情

pragma solidity ^0.8.0;

contract EventExample {
    struct UserInfo{
        address userAddr;
        uint userId;
    }
    UserInfo[] public userInfo;

    event setUserEvent(address addrs, uint ids);

    function setUser(address addr_, uint id_) public {
        userInfo.push(UserInfo(addr_, id_));
        emit setUserEvent(addr_, id_);
    }
}

登录后复制

setUserEvent 事件包含一个地址 (addrs) 和一个整数 (ids)。当我们扫描到这个事件时，data 字段可能如下所示：

'0x00000000000000000000000057384071e06f31aaaa039da92907a0000017691d20000000000000000000000000000000000000000000000000000000000000001'

登录后复制

这个十六进制字符串实际上包含了 addrs 和 ids 的编码值。前 64 个字符（不包括 "0x"）代表 addrs，后 64 个字符代表 ids。

要解码这些值，我们可以使用以下 Python 代码：

from web3 import Web3

data = '0x00000000000000000000000057384071e06f31aaaa039da92907a0000017691d20000000000000000000000000000000000000000000000000000000000000001'

# 提取地址
address_hex = data[2:66]  # 去除 "0x" 并取前 64 个字符
address = Web3.to_checksum_address('0x' + address_hex[24:]) # 移除前导0并转换为checksum address

# 提取ID
id_hex = data[66:] # 取后64个字符
id = int(id_hex, 16) # 将十六进制字符串转换为整数

print(f"Address: {address}")
print(f"ID: {id}")

登录后复制

这段代码首先提取 data 字段中的地址和 ID 的十六进制表示，然后使用 Web3.to_checksum_address 函数将地址转换为校验和地址，并使用 int(id_hex, 16) 函数将 ID 的十六进制表示转换为整数。

注意事项

数据类型匹配： 确保你解码的数据类型与事件定义中的数据类型匹配。例如，如果事件包含一个字符串，你需要使用不同的方法来解码它。
字符串处理： 如果事件中包含字符串，data 字段可能包含字符串的长度信息和实际的字符串数据。解码字符串需要额外的处理步骤。
动态数组和结构体： 对于包含动态数组或结构体的事件，data 字段的结构会更复杂，需要根据合约的 ABI (Application Binary Interface) 进行解码。Web3.py 提供了方便的函数来处理这种情况。
ABI 解码: 使用合约的ABI可以更方便地解码event数据。

from web3 import Web3
import json

# 连接到以太坊节点
w3 = Web3(Web3.HTTPProvider('YOUR_ETHEREUM_NODE_URL'))

# 合约地址
contract_address = 'YOUR_CONTRACT_ADDRESS'

# 合约ABI
contract_abi = json.loads('''
[
    {
        "anonymous": false,
        "inputs": [
            {
                "indexed": false,
                "internalType": "address",
                "name": "addrs",
                "type": "address"
            },
            {
                "indexed": false,
                "internalType": "uint256",
                "name": "ids",
                "type": "uint256"
            }
        ],
        "name": "setUserEvent",
        "type": "event"
    },
    {
        "inputs": [
            {
                "internalType": "address",
                "name": "addr_",
                "type": "address"
            },
            {
                "internalType": "uint256",
                "name": "id_",
                "type": "uint256"
            }
        ],
        "name": "setUser",
        "outputs": [],
        "stateMutability": "nonpayable",
        "type": "function"
    },
    {
        "inputs": [
            {
                "internalType": "uint256",
                "name": "",
                "type": "uint256"
            }
        ],
        "name": "userInfo",
        "outputs": [
            {
                "internalType": "address",
                "name": "userAddr",
                "type": "address"
            },
            {
                "internalType": "uint256",
                "name": "userId",
                "type": "uint256"
            }
        ],
        "stateMutability": "view",
        "type": "function"
    }
]
''')

contract = w3.eth.contract(address=contract_address, abi=contract_abi)

# 创建事件过滤器
event_filter = contract.events.setUserEvent.createFilter(fromBlock=4916476, toBlock=4916576)

# 获取所有事件
for event in event_filter.get_all_entries():
    print(event.args)

登录后复制