mirror of
https://github.com/eosswedenorg/thalos
synced 2026-06-16 04:24:56 +02:00
49 lines
1.5 KiB
Python
49 lines
1.5 KiB
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
|
|
|
|
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_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'])
|
|
|
|
|
|
|