Django и telethon

client = TelegramClient(StringSession(TG_SESSION), TG_APP_ID, TG_API_HASH)
 
@client.on(NewMessage(chats=channels))
async def handler_new_message(event):

client = TelegramClient(StringSession(TG_SESSION), TG_APP_ID, TG_API_HASH)
 
 
@client.on(NewMessage(chats=channels))
async def handler_new_message(event):
    channel_name = None
    channel_nickname = None
    home_page = None
    try:
        if not isinstance(event.message, (MessageMediaPoll, MessageService)):
            for key, channel in CHANNELS.items():
                channel_id = channel.get('id')
                if channel_id == f"-100{event.message.peer_id.channel_id}":
                    channel_name = channel.get('name')
                    channel_nickname = channel.get('nickname')
                    async for page in Page.objects.type(ArticleChannelPage):
                        if page.title == channel_name:
                            home_page = page
 
            slug = slugify(f"Новость {event.message.peer_id.channel_id} {event.message.id}", 'uk')
 
            if channel_name and home_page:
                article_media = 1
                if event.message.message and event.message.grouped_id:
                    msgs = [
                        msg for msg in await client.get_messages(channel_nickname, limit=30)
                        if msg.grouped_id == event.message.grouped_id
                    ]
                    article_media = len([msg for msg in msgs if msg.media])
                    title = event.message.message.split('\n')[0]
                    if len(title) > 100:
                        title = title[: 97] + '...'
                    if not title:
                        title = "Свежая новость" + str(uuid.uuid4())
                    body = event.message.message
                    new_page = await get_new_page(home_page, title, slug, event.message, body, article_media)
                    for msg in msgs:
                        if msg.media:
                            if isinstance(msg.media, MessageMediaPhoto):
                                res = await client.download_media(msg, file=MEDIA_ROOT + '/original_images')
                                await save_image(new_page, res)
 
                            if is_video(msg.media):
                                res = await client.download_media(msg, file=MEDIA_ROOT + '/original_videos')
                                await save_video(new_page, res)
 
                if not event.message.grouped_id:
                    msgs = [event.message]
                    title = f'Фотоновость {uuid.uuid4()}'
                    body = 'Фотоновость'
                    new_page = await get_new_page(home_page, title, slug, event.message, body, article_media)
                    for msg in msgs:
                        if msg.media:
                            if isinstance(msg.media, MessageMediaPhoto):
                                res = await client.download_media(msg, file=MEDIA_ROOT + '/original_images')
                                await save_image(new_page, res)
 
                            if is_video(msg.media):
                                res = await client.download_media(msg, file=MEDIA_ROOT + '/original_videos')
                                await save_video(new_page, res)
    except Exception as e:
        print(e)
 
 
@sync_to_async
def get_new_page(home_page, title, slug, message, body, article_media):
    new_page = ArticlePage(
        title=title,
        slug=slug,
        message_id=message.id,
        body=body,
        published_at=message.date + timedelta(hours=5),
        gallery_count=article_media,
        likes=message.forwards,
        views=message.views
    )
    home_page.add_child(instance=new_page)
    new_page.save_revision().publish()
 
    for tag_ in required_tags.values():
        if tag_ in new_page.body:
            tags = [db_tag.name for db_tag in Tag.objects.all()]
            if tag_[1:] not in tags:
                tag = Tag(
                    name=tag_[1:],
                    slug=get_key(required_tags, tag_)
                )
                tag.save()
            else:
                tag = Tag.objects.filter(name=tag_[1:]).first()
            new_article_tag = ArticlePageTag(
                content_object=new_page,
                tag=tag
            )
            new_article_tag.save()
    return new_page
 
 
@sync_to_async
def save_image(page, filename):
    with pil_image.open(f"{filename}") as img:
        width, height = img.size
    image = Image.objects.create(
        file=f"{filename}",
        title=filename.split('.')[0].split('/')[-1],
        width=width,
        height=height,
    )
 
    article_image = ArticlePageGalleryImage(
        page=page,
        image=image
    )
    article_image.save()
 
 
@sync_to_async
def save_video(page, filename):
    video = Video.objects.create(
        file=f"{filename}",
        title=filename.split('.')[0].split('/')[-1],
    )
    article_video = ArticlePageGalleryVideo(
        page=page,
        video=video
    )
    article_video.save()
 
 
class Command(BaseCommand):
    help = 'Create new Article Page'
 
    def handle(self, *args, **options):
        client.start()
        client.run_until_disconnected()