Create crypto sentiment bot
Tags: #telegram #sentiment #bot #naas_drivers #ai #investors
This notebook is a demo of how you can use naas drivers and Telegram to create a Crypto sentiment bot.
Please note that if you stop the notebook, the bot will not work anymore.
!pip install python-telegram-bot --user
import logging
from telegram.ext import *
import numpy as np
from naas_drivers import newsapi
from naas_drivers import sentiment
from datetime import datetime, timedelta
TELEGRAM_API_KEY = "***********"
NEWSAPI_API_KEY = "***********"
# Set up the logging
logging.basicConfig(format='%(asctime)s - %(name)s - %(levelname)s - %(message)s', level=logging.INFO)
logging.info('Starting Bot...')
#parameters for newsapi
FROM_DATE = (datetime.now()-timedelta(days=1)).replace(microsecond=0).isoformat()
TO_DATE = datetime.now().replace(microsecond=0).isoformat()
#top marketcap coins according to coinmarketcap
coins= ["bitcoin","ethereum", "ripple","dogecoin","cardano",
"polygon","binance","polkadot","uniswap","litecoin",
"chainlink","solana","stellar"]
#connect to Newsapi Naas drivers
newsapi.connect(NEWSAPI_API_KEY)
newsapi.connect()
#user_response
def get_response(user_message):
usr_msg_text = user_message.lower()
if usr_msg_text in coins: #check if returned message has the top coins
data = newsapi.get(q=usr_msg_text,
from_param=FROM_DATE,
to = TO_DATE,
language ="en")
if len(data)==0:#extra check to returned data
sentiment = "No news for this ticker in last 24 hours, try another"
return sentiment
else:
sentiment_df = sentiment.get(data, column_name="title")#sentiment calculation
sentiment = sentiment_df["Score"].mean()
else:
sentiment = 'There is no data for this ticker\n use \help command'
return sentiment
#commands
def start_command(update, context):
update.message.reply_text('''Hello there! I\'m a crypto sentiment bot.
Send me the coin name, I\'ll send you sentiment!''')
def help_command(update, context):
update.message.reply_text('''check the coin names from the list below!
bitcoin\n etherium\n ripple\n dogecoin\n cardano\n polygon
binance\n polkadot\n uniswap\n litecoin\n chainlink\n solana\n stellar''')
#message handler
def handle_message(update, context):
text = str(update.message.text).lower()
logging.info(f'User ({update.message.chat.id}) says: {text}')
# Bot response
sentiment_naas = get_response(text)
update.message.reply_text(sentiment_naas)
#error logs
def error(update, context):
# Logs errors
logging.error(f'Update {update} caused error {context.error}')
# Run the programme
# create an object "bot"
updater = Updater(TELEGRAM_API_KEY, use_context=True)
dp = updater.dispatcher
# bot's command handlers
dp.add_handler(CommandHandler('start', start_command))
dp.add_handler(CommandHandler('help', help_command))
# bot's text handlers
dp.add_handler(MessageHandler(Filters.text, handle_message))
# bot's error handler
dp.add_error_handler(error)
# Run the bot
updater.start_polling(1.0)
updater.idle()
Info: the cell above will stay alive until you press stop, the bot will not respond anymore once the cell is stoped.
Last modified 1mo ago