gocoolp opened a new issue, #69050:
URL: https://github.com/apache/airflow/issues/69050
### Description
DynamoDBHook currently only exposes `write_batch_data()` and
`get_import_status()`. There are no methods for the most common single-item
operations: get, put, update, delete, and query. Every DAG that needs basic
DynamoDB CRUD must implement its own boto3 wrapper outside the hook.
### Use case/motivation
A common Airflow pattern is using DynamoDB as a lightweight job metadata
store — writing job state on start, polling a status field for human approval,
updating on completion. Today none of this can go through DynamoDBHook.
DynamoDBValueSensor works around the gap by calling
`self.hook.conn.Table(...).get_item()` directly, bypassing the
hook layer entirely.
The goal is a hook that covers the full single-item CRUD surface
(get_item, put_item, update_item, delete_item, query) using the boto3 resource
API — plain Python dicts, no typed `{"S": "value"}` format — so DAG authors get
consistent retry config, error handling, and logging without reimplementing it
per project.
### Related issues
_No response_
### Are you willing to submit a PR?
- [x] Yes I am willing to submit a PR!
### Code of Conduct
- [x] I agree to follow this project's [Code of
Conduct](https://github.com/apache/airflow/blob/main/CODE_OF_CONDUCT.md)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
