DynamoDB Recursive Query

index.js

const result = await RecursiveQuery.findByPk({
  pk: 'YOUR_PK',
  keys: "number_primary, status",
});

// -> [{ number_primary: '1', status: 'active' }]

RecursiveQuery.js

class RecursiveQuery {
  static async findByPk(props) {
    const { pk, evaluatedKey = null, data = [], keys = null } = props;

    const queryProps = {
      IndexName: "GSI_INDEX_NAME",
      KeyConditionExpression: "pk = :pk",
      ExpressionAttributeValues: { ":pk": pk },
      ExclusiveStartKey: evaluatedKey,
    };

    if (keys) {
      queryProps["ProjectionExpression"] = keys;
    }

    const result = await client.query(queryProps);
    const { LastEvaluatedKey, Items } = result;

    // update cache
    data.push(Items);

    if (LastEvaluatedKey) {
      props["evaluatedKey"] = LastEvaluatedKey;
      props["data"] = data;

      return await this.findByPk(props);
    }

    // concat arrays
    const items = data.reduce((a, b) => a.concat(b), [])
    console.info(`RecursiveQuery.byPk found is ${items.length} items`);

    return items
  }
}