eosswedenorg/thalos-docs
1
0
Fork 0
mirror of https://github.com/eosswedenorg/thalos-docs synced 2026-06-16 04:34:55 +02:00
Code Releases Activity

docs/api/examples.md: Update python example

Browse source
This commit is contained in:
Henrik Hautakoski 2023-08-28 17:26:10 +02:00
parent 1ac7bc7fa5
commit e8e6c88fb8
1 changed files with 25 additions and 32 deletions
Download patch file Download diff file Expand all files Collapse all files

57
docs/api/examples.md
View file

@ -67,51 +67,44 @@ func main() {
## Python
This example will listen for new atomicasset transfers and print them to standard output.
You can specify multiple channels to listen to by adding them to the `redis_channels` list.
Before you start this script, make sure you have the redis-server running.
::: info NOTE
You need to have the redis-py library installed for this to work
You can install it with pip:
`pip3 install redis`
:::
```python
#!/usr/bin/env python3
# -*- coding: utf-8 -*-
# This example will listen for new actions on the specified channel and log them to a file
# You can specify multiple channels to listen to by adding them to the redis_channels list
# You need to have the redis-py library installed for this to work
# You can install it with pip: pip3 install redis
# Before you start this script, make sure you have the redis-server running
import redis
import logging
import os
import json
abs_path = os.path.dirname(__file__)
# Redis connection options
redis_ip = '127.0.0.1'
redis_port = 6379
redis_db = 0
# Channels to subscribe to, can specify multiple
redis_channels = ['ship::1064487b3cd1a897ce03ae5b6a865651747e2e152090f99c1d19d44e01aea5a4::actions/name/transfer']
# Redis connection
redis_channels = ['ship::1064487b3cd1a897ce03ae5b6a865651747e2e152090f99c1d19d44e01aea5a4::actions/contract/atomicassets/name/logtransfer']
redis_connection = redis.Redis(host=redis_ip, port=redis_port, db=redis_db)
pubsub = redis_connection.pubsub()
pubsub.subscribe(redis_channels)
# Logging options
logging.basicConfig(
filename=f'/{abs_path}/output.log',
level=logging.INFO,
format='%(asctime)s - %(message)s',
datefmt='%Y-%m-%d %H:%M:%S'
)
# Listen for new actions
for message in pubsub.listen():
try:
# Filter out non-message events
if message['type'] == 'message':
# Log and print the message
logging.info(message['data'].decode('utf-8'))
print(message['data'].decode('utf-8'))
except:
# Log if the message failed to decode
logging.info("failed_decode",message['data'])
if message['type'] == "message":
payload = json.loads(message['data'])
data = payload['data']
print("Transfer", "From/To:", data['from'], "->",
data['to'], "Assets:", data['asset_ids'], data['memo'])
```
Output
```
Transfer From/To: agy2a.c.wam -> w4mwy.wam Assets: ['1099546474727', '1099515237687', '1099528028558']
Transfer From/To: fzzm..c.wam -> lstm4.c.wam Assets: ['1099535666180', '1099514473189', '1099524729561']
Transfer From/To: 2ahmc.c.wam -> mmklu.c.wam Assets: ['1099538558402', '1099514074361', '1099514699356']
```