Pyrogram пересылает группу медиафайлов несколько раз?

Question

[plsHelp11]

При отправке сообщения из n-ого кол-ва медиафайлов, бот присылает n-ое кол-во сообщений (т.е. 2 медиафайла - 2 сообщения)
Отправляю в этот канал медиафайлы 2+ одним сообщением:
Сюда приходит 2 одинаковых сообщения:

import pyrogram
import config

channels = []
lm = []

with open('channels.txt','r') as f:
	for channel in f.read().split('\n'):
		channels.append(channel)

app = pyrogram.Client('my_account', config.api_id, config.api_hash)

@app.on_message()
def copy_to_my_channel(app, message):
	print(message)
	if str(message.chat.id) in channels:
		if message.media_group_id == None:
			app.copy_message(from_chat_id = message.chat.id, chat_id = config.my_channel, message_id = message.id)
		else:
			if message.media_group_id not in lm:
				app.copy_media_group(from_chat_id = message.chat.id, chat_id = config.my_channel, message_id = message.id)
				
				lm.append(message.media_group_id)
		print('Пост опубликован')

app.run()

Comments

[Модератор]

Не надо ставить как можно больше тэгов. Лучше оставить один, но конкретный, с которым проблема.
См.п.3.1 Регламента. Также обратите внимание на п.3.6.

Answer 1

[Tema Smirnov]

Проблема заключается в том, что Pyrogram метод copy_media_group() отправляет каждый медиафайл как отдельное сообщение, что приводит к отправке нескольких сообщений вместо одного с группой медиафайлов.

Для исправления этой проблемы вам нужно использовать метод send_media_group() вместо copy_media_group(). Метод send_media_group() отправляет все медиафайлы в одном сообщении, что дает возможность отправлять группу медиафайлов как единое сообщение.

Ниже приведен исправленный код:

import pyrogram
import config

channels = []
lm = []

with open('channels.txt','r') as f:
  for channel in f.read().split('\n'):
    channels.append(channel)

app = pyrogram.Client('my_account', config.api_id, config.api_hash)

@app.on_message()
def copy_to_my_channel(app, message):
  print(message)
  if str(message.chat.id) in channels:
    if message.media_group_id is None:
      app.copy_message(from_chat_id=message.chat.id, chat_id=config.my_channel, message_id=message.message_id)
    else:
      if message.media_group_id not in lm:
        media_group = app.get_media_group(chat_id=message.chat.id, message_id=message.message_id)
        app.send_media_group(chat_id=config.my_channel, media=media_group)
        lm.append(message.media_group_id)
    print('Пост опубликован')

app.run()

В этом коде мы использовали метод get_media_group() для получения группы медиафайлов из оригинального сообщения, а затем отправили ее в новый канал, используя метод send_media_group().

Comments

[plsHelp11]

От души, брачо, а то всю голову сломал

[Tema Smirnov]

plsHelp11, send_media_group() отправляет именно медиа-контент, а не текстовые сообщения.
Документация по этому методу: https://docs.pyrogram.org/api/methods/send_media_group

[plsHelp11]

Tema Smirnov, Заметил что падает несколько одинаковых ошибок, при просмотре media_group, создается несколько медиа групп, под каждые сообщения. Он обработчиком считывает медиа группу 1 медиафайл = 1 сообщение. Как это изменить или обойти я не знаю

[Tema Smirnov]

plsHelp11, метод принимает на вход такой список сущностей (из доки взято): InputMediaPhoto, InputMediaVideo, InputMediaAudio and InputMediaDocument, причём в количестве от 2 до 10 (включительно). Ошибка падает у вас здесь:
https://github.com/pyrogram/pyrogram/blob/master/p...
Как видно, не срабатывает проверка на тип контента, отправляемого в аргументе media.
Надо подебажить что там уходит у вас в этот метод (смотреть в переменную media_group).

[plsHelp11]

Tema Smirnov, получается он просто сообщения закидывает в медиа группу

[Tema Smirnov]

plsHelp11, да, странно.
Значит надо предварительно формировать список из фото/видео которые нужно отправить, вытаскивая их из поля Message'а например photo (там где file_id, file_size и тд).
Изначально хотели просто пересылать в другом место уже отправленное куда-то сообщение содержащее альбом фото/видео, верно?

[Tema Smirnov]

plsHelp11, кстати, уже близки. То что на скрине на 24 строчке - надо бы msg.photo оборачивать в InputMediaPhoto(), причём таким образом: InputMediaPhoto(msg.photo.file_id) - говорим что хотим использовать файл который уже есть на сервах ТГ.

https://docs.pyrogram.org/api/methods/send_media_group (тут пример внизу)
https://docs.pyrogram.org/api/types/InputMediaPhoto

[Tema Smirnov]

plsHelp11, увидел ещё что в коде на скрине есть фильтрация у хендлера сообщений по media_group признаку. Надо бы его убрав и подебажиться.

[Tema Smirnov]

plsHelp11,

скорее всего так

import pyrogram
import config
from pyrogram.types import InputMedia

channels = []
lm = []

with open('channels.txt','r') as f:
  for channel in f.read().split('\n'):
    channels.append(channel)

app = pyrogram.Client('my_account', config.api_id, config.api_hash)

@app.on_message()
def copy_to_my_channel(app, message):
  print(message)
  if str(message.chat.id) in channels:
    if message.media_group_id is None:
      app.copy_message(from_chat_id=message.chat.id, chat_id=config.my_channel, message_id=message.message_id)
    else:
      if message.media_group_id not in lm:
        media_group = app.get_media_group(chat_id=message.chat.id, message_id=message.message_id)
        input_media = [InputMedia(media.photo.file_id, type='photo') if media.photo is not None else InputMedia(media.document.file_id, type='document') for media in media_group]
        app.send_media_group(chat_id=config.my_channel, media=input_media)
        lm.append(message.media_group_id)
    print('Пост опубликован')

app.run()

[plsHelp11]

Tema Smirnov, обработчик новых сообщений видит каждое фото в медиагруппе как новое сообщение, соответственно собирает несколько медиагрупп и отправляет их n-ое кол-во раз

[Tema Smirnov]

Так код же не совсем корректный у вас, перепроверьте ещё раз.
Я создал глобальную переменную и в неё пишу, а когда приходит новое сообщение, сверяю есть ли эта картинка (файл) уже в этом списке глобальном или нет - если есть, то добавляю, объединяя.
Скопируйте прям весь код к себе, посмотрите доработайте под себя.

[plsHelp11]

Tema Smirnov, почему-то на type ругается, уже попробовал и без него, все равно ошибка падает

[Модератор]

plsHelp11, Когда вы регистрировались, вы обещали выполнять Регламент. Ваше сообщение нарушило сразу несколько параграфов Регламента.
Если вы будете продолжать нарушать Регламент, ваши вопросы могут быть удалены, а аккаунт заблокирован модераторами временно или навсегда.
Будьте благоразумны.

[plsHelp11]

Tema Smirnov, в коде выше не нашел глобальной переменной и проверки на наличие, если можешь пришли последний код. Заранее спасибо.

[Tema Smirnov]

plsHelp11,

Скриншот под спойлером:

Код под спойлером:

import pyrogram
import config
from pyrogram.types import InputMedia

channels = []
lm = []

with open('channels.txt','r') as f:
  for channel in f.read().split('\n'):
    channels.append(channel)

app = pyrogram.Client('my_account', config.api_id, config.api_hash)

@app.on_message()
def copy_to_my_channel(app, message):
  print(message)
  if str(message.chat.id) in channels:
    if message.media_group_id is None:
      app.copy_message(from_chat_id=message.chat.id, chat_id=config.my_channel, message_id=message.message_id)
    else:
      if message.media_group_id not in lm:
        media_group = app.get_media_group(chat_id=message.chat.id, message_id=message.message_id)
        input_media = [InputMedia(media.photo.file_id, type='photo') if media.photo is not None else InputMedia(media.document.file_id, type='document') for media in media_group]
        app.send_media_group(chat_id=config.my_channel, media=input_media)
        lm.append(message.media_group_id)
    print('Пост опубликован')

app.run()

Вам надо доработать код под себя - перебирать содержимое медиа-группы, преобразовывая каждую сущность (photo, video, audio и тд) в походящий формат Pyrogram, который ожидается на входе в аргументе media у функции send_media_group.
Если есть с этим сложности, можно попробовать найти на Гитхабе примеры использования этой функции в других репозиториях - глобальным поиском по коду на Гитхабе, или просмотром репозиториев использующий Pyrogram у себя в проектах: https://github.com/pyrogram/pyrogram/network/dependents
И не забывайте конечно же про отладку построковую, используя полноценные IDE под Python или тот же VS Code.

[Rjavii]

Tema Smirnov, изначально проблема не в copy_media_group, а в том что при поступлении медиагруппы приходит несколько сообщений в одном. И copy_media_group срабатывает столько раз, сколько файлов в медиагруппе.
Код можно упростить, обработав первое сообщение и проигнорировав все остальные.
Медиагруппа будет скопирована один раз.
В глобальной переменной lm хранится только id обрабатываемой медиагрупы, больше ничего не нужно.

Answer 2

[SVBazuev]

В Pyrogram надо обрабатывать поток сообщений.
Медиа группа не является контейнером в прямом смысле,
это скорее средство визуальной группировки.

import pyrogram
import config

channels = []
lm = []

with open('channels.txt','r') as f:
  for channel in f.read().split('\n'):
    channels.append(int(channel))

app = pyrogram.Client('my_account', config.api_id, config.api_hash)

@app.on_message(filters.chat(channels))
async def copy_to_my_channel(app, message):

  if message.media_group_id is None:
    app.copy_message(from_chat_id=message.chat.id,
                     chat_id=config.my_channel,
                     message_id=message.message_id
                     )
  else:
    media_group = await client.get_media_group(
        message.chat.id, message.id)

    output_line = (
      f"Это первое сообщение, id: {message.id}"
      if message.id == media_group[0].id
      else f"Следующее сообщение, id: {message.id}"
      if message.id != media_group[-1].id
      else f"Это последнее сообщение в медиа-группе, id: {message.id}"
      )
    print(output_line)

    # Обрабатывать сообщения в потоковом режиме
    if message.video:
      _media = await client.download_media(
      message.video.file_id, in_memory=True,
      file_name=message.video.file_name
      )

    elif message.audio:
      _media = await client.download_media(
        message.audio.file_id, in_memory=True
        )

    elif message.photo:
      _media = await client.download_media(
        message.photo.file_id, in_memory=True
        )

    elif message.document:
      _media = await client.download_media(
        message.document.file_id, in_memory=True,
        file_name=message.document.file_name
        )

    lm.append(_media)

    # Отправлять к себе в канал надо после обработки последнего сообщения
    if message.id == media_group[-1].id:
      await client.copy_media_group(
        chat_id=config.my_channel, message.chat.id, message.id
        )
      print('Пост опубликован')

app.run()

Успехов!