Presto以太坊连接器

叁歲伎倆 2022-12-03 12:51 150阅读 0赞

# Presto以太坊连接器 #

在以太坊区块链上释放Presto交互式SQL查询的功能

### 介绍 ###

[Presto][]是一个功能强大的交互式查询引擎，只要存在与源的连接器，它就可以对任何内容（包括MySQL，HDFS，本地文件，Kafka）运行SQL查询。

这是与以太坊区块链数据的Presto连接器。有了这个连接器，您就可以开始进行以太坊区块链分析工作，而不必知道如何使用精巧的Javascript API。

### 先决条件 ###

有一个可以连接的以太坊客户端。有2个选项：

1.  在本地运行[Geth][]或[Parity][]。
2.  使用[Infura][]（云中托管的以太坊客户端）。

### 注意 ###

指定一个块范围在这里可以（例如`WHERE block.block_number > x AND block.block_number < y`，或`WHERE transaction.tx_blocknumber > x AND transaction.tx_blocknumber < y`，或`WHERE erc20.erc20_blocknumber > x AND erc20.erc20_blocknumber < y`）。块号是默认值，并且是唯一可以下推以缩小数据扫描范围的谓词。没有块范围的查询将导致presto从第一个块一直检索块，这将花费很长时间。

### 用法 ###

1.  [安装Presto][Presto 1]。*按照该页面上的说明创建相关的配置文件。*  
    在此步骤结束时，您的presto安装文件夹结构应如下所示：
    
        ├── bin
        ├── lib
        ├── etc
        │   ├── config.properties
        │   ├── jvm.config
        │   └── node.properties
        ├── plugin
2.  [安装Presto CLI][Presto CLI]
3.  克隆此仓库并运行`mvn clean package`以构建插件。您将在`target`文件夹中找到内置的插件。
4.  将插件加载到Presto  
    a。在中创建以太坊连接器配置`etc`。  
    `$ mkdir -p etc/catalog && touch etc/catalog/ethereum.properties`  
    将以下内容粘贴到ethereum.properties中：
    
        connector.name=ethereum
        
        # You can connect through Ethereum HTTP JSON RPC endpoint
        # IMPORTANT - for local testing start geth with rpcport
        # geth --rpc --rpcaddr "127.0.0.1" --rpcport "8545"
        ethereum.jsonrpc=http://localhost:8545/
        
        
        # Or you can connect through IPC socket
        # ethereum.ipc=/path/to/ipc_socketfile
        
        # Or you can connect to Infura
        # ethereum.infura=https://mainnet.infura.io/<your_token>
    
    b。将构建的插件复制并解压缩到presto插件文件夹中
    
        $ mkdir -p plugin/ethereum \
          && cp <path_to_this_repo>/target/presto-ethereum-*-plugin.tar.gz . \
          && tar xfz presto-ethereum-*-plugin.tar.gz -C plugin/ethereum --strip-components=1
    
    在此步骤结束时，您的presto安装文件夹结构应如下所示：
    
        ├── bin
        ├── lib
        ├── etc
        │   ├── catalog
        │   │   └── ethereum.properties
        │   ├── config.properties
        │   ├── jvm.config
        │   └── node.properties
        ├── plugin
        │   ├── ethereum
        │   │   └── <some jars>
5.  妳去 现在，您可以启动presto服务器，并通过presto-cli查询：

$ bin/launcher start $ presto-cli --server localhost:8080 --catalog ethereum --schema default

### 用例 ###

受[前100000块分析的][100000]启发，以下SQL查询部分捕获了该文章中描述的内容。

*  前50个区块时间（以秒为单位）

SELECT b.bn, (b.block_timestamp - a.block_timestamp) AS delta
    FROM
        (SELECT block_number AS bn, block_timestamp
        FROM block
        WHERE block_number>=1 AND block_number<=50) AS a
    JOIN
        (SELECT (block_number-1) AS bn, block_timestamp
        FROM block
        WHERE block_number>=2 AND block_number<=51) AS b
    ON a.bn=b.bn
    ORDER BY b.bn;

平均区块时间（从创始到区块10000的第200个区块）

WITH
    X AS (SELECT b.bn, (b.block_timestamp - a.block_timestamp) AS delta
            FROM
                (SELECT block_number AS bn, block_timestamp
                FROM block
                WHERE block_number>=1 AND block_number<=10000) AS a
            JOIN
                (SELECT (block_number-1) AS bn, block_timestamp
                FROM block
                WHERE block_number>=2 AND block_number<=10001) AS b
            ON a.bn=b.bn
            ORDER BY b.bn)
    SELECT min(bn) AS chunkStart, avg(delta)
    FROM
        (SELECT ntile(10000/200) OVER (ORDER BY bn) AS chunk, * FROM X) AS T
    GROUP BY chunk
    ORDER BY chunkStart;

前10万个区块中最大的矿工（地址，区块，％）

ELECT block_miner，count（*）AS num，count（*）/ 100000。0  AS PERCENT
     FROM block
     WHERE block_number <= 100000 
    GROUP BY block_miner
     ORDER BY num DESC 
    LIMIT  15 ;

*  最近100个区块中的ERC20代币移动

SELECT erc20_token，SUM（erc20_value）FROM erc20
     WHERE erc20_blocknumber > =  4147340  AND erc20_blocknumber <= 4147350 
    GROUP BY erc20_token;

描述数据库结构

### Web3功能 ###

除了各种内置的[Presto函数之外][Presto 2]，还移植了一些web3函数，以便可以直接与SQL语句内联调用它们。当前，支持的web3功能是

1.  [来自魏][Link 1]
2.  [到魏][Link 2]
3.  [eth\_gas价格][eth_gas]
4.  [eth\_blockNumber][eth_blockNumber]
5.  [eth\_getBalance][eth_getBalance]
6.  [eth\_getTransactionCount][eth_getTransactionCount]

### 故障排除 ###

*  您必须使用python2。如果使用Python3，将会收到无效的语法错误。

-> bin/launcher start File "/your_path/presto-server-0.196/bin/launcher.py", line 38 except OSError, e: ^ SyntaxError: invalid syntax

*  仅使用Java 8。如果使用错误的Java版本，则可能会出现以下错误。

Unrecognized VM option 'ExitOnOutOfMemoryError' Did you mean 'OnOutOfMemoryError=<value>'? Error: Could not create the Java Virtual Machine. Error: A fatal exception has occurred. Program will exit.

源码地址：[https://github.com/xiaoyao1991/presto-ethereum][https_github.com_xiaoyao1991_presto-ethereum]

[Presto]: https://prestosql.io/
[Geth]: https://github.com/ethereum/go-ethereum
[Parity]: https://github.com/paritytech/parity
[Infura]: https://infura.io/
[Presto 1]: https://prestosql.io/docs/current/installation/deployment.html
[Presto CLI]: https://prestosql.io/docs/current/installation/cli.html
[100000]: https://blog.ethereum.org/2015/08/18/frontier-first-100k-blocks/
[Presto 2]: https://prestodb.io/docs/current/functions.html
[Link 1]: https://github.com/ethereum/wiki/wiki/JavaScript-API#web3fromwei
[Link 2]: https://github.com/ethereum/wiki/wiki/JavaScript-API#web3towei
[eth_gas]: https://github.com/ethereum/wiki/wiki/JavaScript-API#web3ethgasprice
[eth_blockNumber]: https://github.com/ethereum/wiki/wiki/JavaScript-API#web3ethblocknumber
[eth_getBalance]: https://github.com/ethereum/wiki/wiki/JavaScript-API#web3ethgetbalance
[eth_getTransactionCount]: https://github.com/ethereum/wiki/wiki/JavaScript-API#web3ethgettransactioncount
[https_github.com_xiaoyao1991_presto-ethereum]: https://github.com/xiaoyao1991/presto-ethereum