createReadStream() behavior replication in v3

[jirimoravcik]

In SDK v2, one could do:

const docClient = new aws.DynamoDB.DocumentClient(...);
const stream = docClient.query(queryParams).createReadStream();

How to replicate this behavior in v3?
Thanks

[yenfryherrerafeliz]

Hi @jirimoravcik, to accomplish this with v3 you would need to add a middleware to the client as follow:

import {DynamoDBClient} from "@aws-sdk/client-dynamodb";
import {DynamoDBDocumentClient} from "@aws-sdk/lib-dynamodb";

const client = new DynamoDBClient({region: "us-east-2"});
client.middlewareStack.addRelativeTo(
    (next) => async (args) => {
        const { response } = await next(args);
        const readableStream = response.body; // HERE IS YOUR READABLE STREAM
        
        return {
            response,
        };
    },
    {
        name: "customResponseBodyMiddleware",
        toMiddleware: "deserializerMiddleware",
        relation: "after",
        step: "deserialize",
        override: true,
    }
);
const documentClient = DynamoDBDocumentClient.from(client);

Please let me know if that helps!

[github-actions[bot]]

Hello! Reopening this discussion to make it searchable.