如何将可迭代对象转换为流？

Question

如果我有一个包含字符串的可迭代对象，有没有一种简单的方法可以将其转换为流？我想做这样的事情：

def make_file():
    yield "hello\n"
    yield "world\n"

output = tarfile.TarFile(…)
stream = iterable_to_stream(make_file())
output.addfile(…, stream)

Answer 1

一个伟大的Mechanical snail 的答案的一点修改版本。在这里，readinto(b) 实现对底层迭代器进行了多次调用，以便为给定的可写字节类对象b 的大小收集尽可能多的字节。

class IteratorReader(io.RawIOBase):

    def __init__(self, iterator):
        self.iterator = iterator
        self.leftover = []

    def readinto(self, buffer: bytearray) -> Optional[int]:
        size = len(buffer)
        while len(self.leftover) < size:
            try:
                self.leftover.extend(next(self.iterator))
            except StopIteration:
                break

        if len(self.leftover) == 0:
            return 0

        output, self.leftover = self.leftover[:size], self.leftover[size:]
        buffer[:len(output)] = output
        return len(output)

    def readable(self) -> bool:
        return True

及用法：

def iterator1():
    for i in ('a', 'b', 'c', 'd', 'e', 'f', 'g'):
        res = i * 3
        yield res.encode("utf8")


iterreader = IteratorReader(iterator1())
while True:
    r = iterreader.read(4)
    if not r:
        break
    print(r)

Answer 2

这是我的流式迭代器 urllib3 的实验分支，支持通过可迭代的流式分块请求：

class IterStreamer(object):
    """
    File-like streaming iterator.
    """
    def __init__(self, generator):
        self.generator = generator
        self.iterator = iter(generator)
        self.leftover = ''

    def __len__(self):
        return self.generator.__len__()

    def __iter__(self):
        return self.iterator

    def next(self):
        return self.iterator.next()

    def read(self, size):
        data = self.leftover
        count = len(self.leftover)

        if count < size:
            try:
                while count < size:
                    chunk = self.next()
                    data += chunk
                    count += len(chunk)
            except StopIteration:
                pass

        self.leftover = data[size:]

        return data[:size]

带有上下文的来源： https://github.com/shazow/urllib3/blob/filepost-stream/urllib3/filepost.py#L23

相关单元测试： https://github.com/shazow/urllib3/blob/filepost-stream/test/test_filepost.py#L9

唉，这个代码还没有进入稳定分支，因为对无大小块请求的支持很差，但它应该是你尝试做的一个很好的基础。有关如何使用它的示例，请参阅源链接。

Answer 3

Python 3 具有 a new I/O stream API (library docs)，取代了旧的类文件对象协议。 （新的 API 在 Python 2 中的 io 模块中也可用，并且它向后兼容类文件对象协议。）

Here's an implementation for the new API，在 Python 2 和 3 中：

import io

def iterable_to_stream(iterable, buffer_size=io.DEFAULT_BUFFER_SIZE):
    """
    Lets you use an iterable (e.g. a generator) that yields bytestrings as a read-only
    input stream.

    The stream implements Python 3's newer I/O API (available in Python 2's io module).
    For efficiency, the stream is buffered.
    """
    class IterStream(io.RawIOBase):
        def __init__(self):
            self.leftover = None
        def readable(self):
            return True
        def readinto(self, b):
            try:
                l = len(b)  # We're supposed to return at most this much
                chunk = self.leftover or next(iterable)
                output, self.leftover = chunk[:l], chunk[l:]
                b[:len(output)] = output
                return len(output)
            except StopIteration:
                return 0    # indicate EOF
    return io.BufferedReader(IterStream(), buffer_size=buffer_size)

示例用法：

with iterable_to_stream(str(x**2).encode('utf8') for x in range(11)) as s:
    print(s.read())

Answer 4

由于看起来没有“标准”的做法，我拼凑了一个简单的实现：

class iter_to_stream(object):
    def __init__(self, iterable):
        self.buffered = ""
        self.iter = iter(iterable)

    def read(self, size):
        result = ""
        while size > 0:
            data = self.buffered or next(self.iter, None)
            self.buffered = ""
            if data is None:
                break
            size -= len(data)
            if size < 0:
                data, self.buffered = data[:size], data[size:]
            result += data
        return result

Answer 5

TarFile 接受任何提供file-like interface 的东西——因此您可以使用StringIO（如果您使用的是Python 3.X，则使用io.StringIO）来生成您需要的TarFile.addfile() 或者您可以创建自己的提供file-like interface 并产生您需要的类。

Answer 6

起点：

class iterable_to_stream:
    def __init__(self, iterable):
        self.iter = iter(iterable)

    def read(self):
        try:
            return self.iter.next()
        except StopIteration:
            return ""