post_to_channel.py

import os
import sys
import logging
import asyncio
import aiotg
import redis

api_token = os.environ.get('API_TOKEN')
bot_name = os.environ.get('BOT_NAME')
bot = aiotg.Bot(api_token=api_token, name=bot_name)
channel = bot.channel(os.environ.get('CHANNEL_NAME', '@BozorboyNews'))
redis_url = os.environ.get('REDIS_URL', 'redis://localhost:6379/0')
logger = logging.getLogger('bot')
logging.basicConfig(level=logging.DEBUG)


async def main():
    r = redis.from_url(redis_url)
    post = r.spop('unpublished_posts')

    if not post:
        sys.exit(0)

    text = post.decode('utf-8')

    if not r.sismember('published_posts', text):
        logger.info('Publishing post {text} to channel...'.format(text=text))
        await channel.send_text(text, disable_web_page_preview=True)
        r.sadd('published_posts', text)

loop = asyncio.get_event_loop()
loop.run_until_complete(main())