2.4 KiB
Moonstream Python client
This is the Python client library for the Moonstream API.
Installation
This library assumes you are using Python 3.6 or greater.
Install using pip:
pip install moonstream
Usage
- Source environment variable with access token to Moonstream, you can create one on page https://moonstream.to/account/tokens/
access_token = os.environ.get("MOONSTREAM_ACCESS_TOKEN")
- Create an object of Moonstream client and authorize
mc = Moonstream()
mc.authorize(access_token)
create_stream method
Return a stream of event for time range.
From timestamp to None, from bottom to top
When end_time is not set.
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)
In this case we will be receiving events from bottom of history to recent time in next order:
[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...
From timestamp to timestamp, from top to bottom
When start_time is greater then 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)
Stream of event packs will be generating from recent timestamp to older and inner list of transactions for each pack will be in most recent to older event timestamp range:
[1637839280, ..., 1637838094]
[1637838086, ..., 1637836340]
...
[1637834488, ..., 1637832699]
[1637832676, ..., 1637830903]
From timestamp to timestamp, from bottom to top
When start_time is less then 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)
You start receiving list of older events from bottom of history to newest:
[1637832676, ..., 1637830903]
[1637834488, ..., 1637832699]
...
[1637838086, ..., 1637836340]
[1637839280, ..., 1637838094]