ddb-scan.ts

import {parallelScan} from './src';

(async () => {
  console.time('fetch');

  const data = await parallelScan(
    {
      TableName: 'notifications',
      FilterExpression: '#updatedAt > :updatedAt and #senderId = :senderId',
      ExpressionAttributeNames: {
        '#updatedAt': 'updatedAt',
        '#senderId': 'senderId',
      },
      ExpressionAttributeValues: {
        ':updatedAt': '2022-01-01T00:00:00.000Z',
        ':senderId': 'foo-1',
      },
      ProjectionExpression: 'updatedAt',
    },
    {concurrency: 250}
  );

  console.timeEnd('fetch');

  console.log(data);
})();