Moonstream Python 客户端

这是 Moonstream API 的 Python 客户端库。

安装

该库假定您使用的是 Python 3.6 或更高版本。

使用安装pip：

pip install moonstream

用法

• 带有 Moonstream 访问令牌的源环境变量，您可以在页面https://moonstream.to/account/tokens/上创建一个

access_token = os.environ.get("MOONSTREAM_ACCESS_TOKEN")

• 创建 Moonstream 客户端对象并授权

mc = Moonstream()
mc.authorize(access_token)

create_stream 方法

返回时间范围的事件流。

从时间戳到无，从下到上

什么时候end_time没有设置。

for events in mc.create_stream(
    start_time=1637834400, end_time=None, q="type:ethereum_blockchain"
):
    event_timestamp_list = [e["event_timestamp"] for e in events["events"]]
    print(event_timestamp_list)

在这种情况下，我们将按下一个顺序接收从历史底部到最近时间的事件：

[1637836177, ..., 1637834440]
[1637837980, ..., 1637836226]
# Until we will get latest event,
# then we will be receiving empty lists
[]
[]
# Until new events will be available
[1637839306, 1637839306, 1637839306, 1637839306]
[]
# Continuing...

从时间戳到时间戳，从上到下

什么时候start_time比较大end_time。

for events in mc.create_stream(
    start_time=1637839281, end_time=1637830890, q="type:ethereum_blockchain"
):
    event_timestamp_list = [e["event_timestamp"] for e in events["events"]]
    print(event_timestamp_list)

事件包流将从最近的时间戳生成到较旧的时间戳，每个包的内部事务列表将在最近到较旧的事件时间戳范围内：

[1637839280, ..., 1637838094]
[1637838086, ..., 1637836340]
...
[1637834488, ..., 1637832699]
[1637832676, ..., 1637830903]

从时间戳到时间戳，从下到上

什么时候start_time少呢end_time。

for events in mc.create_stream(
    start_time=1637830890, end_time=1637839281, q="type:ethereum_blockchain"
):
    event_timestamp_list = [e["event_timestamp"] for e in events["events"]]
    print(event_timestamp_list)

您开始接收从历史底部到最新的旧事件列表：

[1637832676, ..., 1637830903]
[1637834488, ..., 1637832699]
...
[1637838086, ..., 1637836340]
[1637839280, ..., 1637838094]