> For clean Markdown of any page, append .md to the page URL.
> For a complete documentation index, see https://docs.nvidia.com/aistore/llms.txt.
> For full documentation content, see https://docs.nvidia.com/aistore/llms-full.txt.
> For AI client integration (Claude Code, Cursor, etc.), connect to the MCP server at https://docs.nvidia.com/aistore/_mcp/server.

# aistore.sdk.batch.extractor.zip_stream_extractor

## Module Contents

### Classes

| Name                                                                                         | Description                                           |
| -------------------------------------------------------------------------------------------- | ----------------------------------------------------- |
| [`ZipStreamExtractor`](#aistore-sdk-batch-extractor-zip_stream_extractor-ZipStreamExtractor) | Class for extracting batch .zip streams from AIStore. |

### Data

[`logger`](#aistore-sdk-batch-extractor-zip_stream_extractor-logger)

### API

```python
class aistore.sdk.batch.extractor.zip_stream_extractor.ZipStreamExtractor()
```

**Bases:** [ArchiveStreamExtractor](/python/aistore/sdk/batch/extractor/archive_stream_extractor#aistore-sdk-batch-extractor-archive_stream_extractor-ArchiveStreamExtractor)

Class for extracting batch .zip streams from AIStore.

Integrates with MossReq/MossResp objects to provide proper metadata mapping.

```python
aistore.sdk.batch.extractor.zip_stream_extractor.ZipStreamExtractor.extract(
    response: requests.Response,
    data_stream: typing.Union[io.BytesIO, typing.Any],
    moss_req: aistore.sdk.batch.types.MossReq,
    moss_resp: typing.Optional[aistore.sdk.batch.types.MossResp] = None
) -> typing.Generator[typing.Tuple[aistore.sdk.batch.types.MossOut, bytes], None, None]
```

Extract from zip archive stream.

Note: ZIP format requires random access, so the entire stream
is loaded into memory before extraction begins.

**Parameters:**

HTTP response

Archive data

Original request

Response metadata (None for streaming)

```python
aistore.sdk.batch.extractor.zip_stream_extractor.logger = get_logger(__name__)
```