如何使用avro处理我无法查找的流?

我对此不太清楚,这可能不是答案。 我觉得

diter = datafile.DataFileReader(..) 

返回迭代器,以便可以执行以下操作

for data in diter:
    ....

如果我错了,纠正我。

重温我的答案:

你说得对,datafile.datafile reader不能很好地处理搜索失败的读卡器。

它使用接受读卡器的avro.io.binarydecoder。

class BinaryDecoder(object):
    """Read leaf values."""
    def __init__(self, reader):
        """
    reader is a Python object on which we can call read, seek, and tell.
    """
    self._reader = reader

您所能做的就是创建自己的读卡器类,它确实提供了这些功能——读取、查找和告诉,但在内部使用botoS3库来读取数据。