将 s3 中的 docx/pdf 文件转换为 txt 文件，并使用 python + boto3 存储在 s3 中

Question

我的情况是我在S3中存储了docx/pdf文件。我需要将这些文件转换为 txt 文件，然后将转换后的文件存储在 S3 中。我正在使用docx2txt库（docx2txt 0.5：https://pypi.python.org/pypi/docx2txt/）。下面是我的代码和错误：

import boto3
import docx2txt
s3 = boto3.resource('s3')
bucket = s3.Bucket('client-shared-file')
obj = s3.Object(bucket.name, 'key name');
text = docx2txt.process(obj.get()['Body']) //I also tried .read() but still not work
print(text)

错误：

Traceback (most recent call last):
  File ".../PycharmProjects/untitled/test.py", line 6, in <module>
    text = docx2txt.process(obj.get()['Body'])
  File "...Anaconda3libsite-packagesdocx2txtdocx2txt.py", line 76, in process
    zipf = zipfile.ZipFile(docx)
  File "...Anaconda3libzipfile.py", line 1026, in __init__
    self._RealGetContents()
  File "...Anaconda3libzipfile.py", line 1089, in _RealGetContents
    endrec = _EndRecData(fp)
  File "...Anaconda3libzipfile.py", line 241, in _EndRecData
    fpin.seek(0, 2)
AttributeError: 'StreamingBody' object has no attribute 'seek'

这是对象：

{
    'ResponseMetadata': {
        'RequestId': 'RequestId', 
        'HostId': 'HostId', 
        'HTTPStatusCode': 200
        }, 
    'AcceptRanges': 'bytes', 
    'Metadata': {}, 
    'ContentType': 'application/msword', 
    'ContentLength': 66235, 
    'Body': <botocore.response.StreamingBody object at 0x00000219C885FF28>, 
    'ETag': '"ETag"', 
    'LastModified': 'LastModified'
}

似乎 boto3 StreamingBody 不能用作 docx2txt 函数中的 docx 文件。无论如何可以在 s3 上转换这些文件，或者我在此过程中做错了什么？非常感谢帮助。提前谢谢。

Answer 1

body=obj.get()['Body'].read()
buffer = io.BytesIO()
buffer.write(body)
text = docx2txt.process(buffer)

将对象转换为 BytesIO，如上面的代码所示。

Answer 2

>StreamingBody不是一个可搜索的文件，docx2txt 似乎想要。您需要将整个文件缓冲为其他内容。例如，BytesIO可能有效。