Solana区块链数据抓取

由于区块链上的交易可以作为公共数据访问，我们可以开发一个抓取客户端来检索每个区块中的数据进行分析。

这里是Rust API中我用来访问Solana区块链的代码。

创建RPC客户端。

RpcClient::new(‘https://solana-api.projectserum.com’.to_string());

获取当前Epoch

client.get_epoch_info().unwrap();

获取Epoch间隔的时隙号(absolute_slot)。

start_slot = epoch_start.absolute_slot; end_slot =

epoch_end.absolute_slot;

获取两个时隙号之间的交易区块。

let blocks = _client.get_blocks(start, Some(end)).unwrap();

for s in blocks {

let _blk = _client.get_block(s);

// get the data we need from each block

每个区块包含一个交易列表。每个交易都有元数据、消息、交易前和交易后的余额以及账户列表。

有许多不同种类的信息。从测试中，我发现以下2条消息将表示转账。

‘Program 11111111111111111111111111111111 success”Program log: Instruction: Transfer’

我过滤掉了消息，然后从预平衡中减去后平衡。它可以追踪在帐户键之间转移了多少lamport。

我为每个交易提取这些信息，并将其输入到Neo4J图形数据库中，以构建不同帐户之间所有转账的关系。这是在 Neo4J 中建立传输关系的 Cypher Query。

MATCH (ac1:Account {key: $ckey}),(ac2:Account {key: $dkey})

MERGE (ac1)-[rel:TRANSFER_TO]->(ac2)’)

下面显示了转账图的可视化。每个红色节点代表一个Solana帐户，直接链接是transfer_to关系。

图中显示了几个繁忙的集群。

图形数据库可以支持许多分析，例如查询哪些帐户是最受欢迎的帐户。我们可以很容易地追踪到经常转账到某个可疑账户的账户群。这有助于识别违法行为。

Source：https://medium.com/coinmonks/solana-blockchain-data-scraping-2cca0dc056aa