3

Всем доброго времени суток. В данном коде присутствует работа с изображением в переменной data идет создание даты для пост запроса, файлы можно только один раз читать я это понял, но я не понял, почему ошибка не ушла, когда я в коде создал еще 1 дату?

async def _upload_file_to_vk(self, upload_url, data):
    async with self.manager.session.post(upload_url, data=data) as resp:
        if resp.status != 200:
            return None

        upload_result_text = await resp.text()

        if not upload_result_text:
            return None

        try:
            upload_result = json.loads(upload_result_text)

            if "error" in upload_result:
                raise RuntimeError

        except RuntimeError:
            return None

        return upload_result
async def upload_photo(self, file, **kwargs):

    if kwargs.get("peer_id") is None:
        peer_id = self.peer_id

    else:
        peer_id = kwargs.get("peer_id")

    upload_data = await self.manager.request(
        "photos.getMessagesUploadServer", peer_id=peer_id
    )

    if upload_data.error:
        return None

    upload_url = upload_data.response["upload_url"]

    data = aiohttp.FormData()
    data.add_field("photo", file, filename="image.png")

    upload_result = await self._upload_file_to_vk(upload_url, data)

    if not upload_result:
        return None

    attachments = await self.manager.request(
        "photos.saveMessagesPhoto", **upload_result
    )

    #Если произошла ошибка пробуем загрузить тот же самый аттач без peer_id
    if attachments.error:
        upload_data = await self.manager.request(
        "photos.getMessagesUploadServer", peer_id=None
        )

        if upload_data.error:
            return None

        upload_url = upload_data.response["upload_url"]

        data = aiohttp.FormData()
        data.add_field("photo", file, filename="image.png")

        upload_result = await self._upload_file_to_vk(upload_url, data)

        if not upload_result:
            return None

        attachments = await self.manager.request(
            "photos.saveMessagesPhoto", **upload_result
        )

        if attachments.error:
            return None

    return self.manager.create_attachment(
        attachments.response[0], "photo"
    )


f = io.BytesIO()
img2.save(f, format='png')
f.seek(0)
at = await env.upload_photo(f)
f.close()

Получаю ошибку:

File "plugins/content/certificate.py", line 50, in certificate 
at = await env.upload_photo(f) 
File "/root/grizzly/kutana/manager/vk/environment.py", line 146, in upload_photo 
upload_result = await self._upload_file_to_vk(upload_url, data) 
File "/root/grizzly/kutana/manager/vk/environment.py", line 13, in _upload_file_to_vk 
async with self.manager.session.post(upload_url, data=data) as resp: 
File "/usr/local/lib/python3.6/dist-packages/aiohttp/client.py", line 1005, in __aenter__ 
self._resp = await self._coro 
File "/usr/local/lib/python3.6/dist-packages/aiohttp/client.py", line 466, in _request 
ssl=ssl, proxy_headers=proxy_headers, traces=traces) 
File "/usr/local/lib/python3.6/dist-packages/aiohttp/client_reqrep.py", line 294, in __init__ 
self.update_body_from_data(data) 
File "/usr/local/lib/python3.6/dist-packages/aiohttp/client_reqrep.py", line 479, in update_body_from_data 
body = body() 
File "/usr/local/lib/python3.6/dist-packages/aiohttp/formdata.py", line 148, in __call__ 
return self._gen_form_data() 
File "/usr/local/lib/python3.6/dist-packages/aiohttp/formdata.py", line 142, in _gen_form_data 
self._writer.append_payload(part) 
File "/usr/local/lib/python3.6/dist-packages/aiohttp/multipart.py", line 798, in append_payload 
size = payload.size 
File "/usr/local/lib/python3.6/dist-packages/aiohttp/payload.py", line 360, in size 
position = self._value.tell() 
ValueError: I/O operation on closed file.

Не понимаю, что я делаю не так?

11
  • Если убрать f.close() ошибка останется? Вообще закрытие для BytesIO не обязательно.
    – insolor
    11 фев 2020 в 8:20
  • Буду дома попробую, отпишусь.
    – Lumo
    11 фев 2020 в 17:12
  • @insolor К сожалению нет, ошибка все так же появляется(
    – Lumo
    11 фев 2020 в 17:54
  • Это единственный вызов метода close?
    – insolor
    11 фев 2020 в 17:55
  • да единственный в конце уже идет отправка f = io.BytesIO() img2.save(f, format='png') f.seek(0) at = await env.upload_photo(f) return await env.reply("Ваш сертификат готов!", attachment=at)
    – Lumo
    11 фев 2020 в 17:56

2 ответа 2

4

Вы не так поняли. Файлы можно читать неограниченное кол-во раз, но после каждого прочтения файла следует его закрывать, т.к. нередко Python начинает кричать неблагим матом и выводить кракозябры. Также возможно что вы не открыли нужный файл (самое первое обращение, например при работе с txt: t = open('myfile.txt')), либо прописали неправильное название. Вполне возможно что он пытается обратиться к файлу в совершенно другой директории (отличной от расположения вашего файла), если найду пример правильного обращения к файлу, то вставлю сюда.


Вам надо прописать:

import os #В начале файла
data = aiohttp.FormData()
data.add_field("photo", file, filename=os.path.dirname(os.path.abspath(__file__))+"/имя_файла.расширение") #Таким образом файл будет искаться в одной директории с кодом.

Также вам нужно f.close() использовать в другом месте, после вызова файла в двух местах внутри функции. Так вам не придётся закрывать файл вручную.

3
  • I/O operation on closed file. не имеет отношения к ошибкам открытия (файл в другой директории и т.д.), тем более что в вопросе идет работа с BytesIO (объект в памяти, ведущий себя как файл), а не с файлом на диске. Ошибка говорит именно о том, что к объекту идет обращение после f.close().
    – insolor
    11 фев 2020 в 8:45
  • @insolor, к сожалению с BytesIO никогда не работал, потому предположил что из-за чего может быть ошибка
    – DGDays
    11 фев 2020 в 8:59
  • Привет ваш пример у меня работает, но тут уже код с BytesIO. Именно с ним у меня трабл с простым open проблем никаких нет.
    – Lumo
    11 фев 2020 в 17:55
2
+100

По результатам обсуждения в комментариях пришли к выводу, что при POST запросе отправляемый файловый объект закрывается. Поэтому такой вариант: пишем изображение в объект BytesIO, но в upload_photo передаем не этот же объект, а данные из него (получаем их с помощью метода getvalue). Внутри upload_photo перед каждой отправкой данных заново создаем объект BytesIO.

async def upload_photo(self, file_data: bytes, **kwargs):

    # ...

    data = aiohttp.FormData()
    data.add_field("photo", io.ByteIO(file_data), filename="image.png")

    upload_result = await self._upload_file_to_vk(upload_url, data)

    if not upload_result:
        return None

    attachments = await self.manager.request(
        "photos.saveMessagesPhoto", **upload_result
    )

    #Если произошла ошибка пробуем загрузить тот же самый аттач без peer_id
    if attachments.error:
        # ...

        data = aiohttp.FormData()
        data.add_field("photo", io.BytesIO(file_data), filename="image.png")

        upload_result = await self._upload_file_to_vk(upload_url, data)

        # ...


f = io.BytesIO()
img2.save(f, format='png')
at = await env.upload_photo(f.getvalue())

Также можно просто прикреплять вложение как байты, а не как файловый объект:

data.add_field("photo", file_data, filename="image.png")
6
  • Такой вопрос еще у меня во многих местах так же вот такая загрузка фотографий она не сломается? with open(get_path(__file__, "assets/pizza.png"), "rb") as fh: image = await env.upload_photo(fh.read())
    – Lumo
    11 фев 2020 в 18:42
  • Ну fh.read() и так читает файл в виде набора байт целиком, и в моем варианте f.getvalue() тоже получает набор байт. Если у вас это работало, то возможно внутри upload_photo не нужно данные в BytesIO оборачивать. В любом случае, если сделать как в ответе, то сломаться не должно.
    – insolor
    11 фев 2020 в 18:45
  • Спасибо огромное за помощь, желаю успехов. Я побежал пытаться)
    – Lumo
    11 фев 2020 в 18:48
  • Теперь вот такая ошибка( TypeError: a bytes-like object is required, not '_io.BytesIO' Я использовал at = await env.upload_photo(f.getvalue())
    – Lumo
    11 фев 2020 в 18:53
  • На какой строке ошибка?
    – insolor
    11 фев 2020 в 18:55

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.