We streams the data from DynamoDB to S3, using Kinesis, Kinesis FireHose and formatting Lambda, And use Airflow and DBT to create Iceberg tables on top of it and query it via Athena.
The initial load is being done via federation, we are using federation to perform data checks and validation as part of the process.
Thanks: Hagai A. (s.DE @aiOla)