Do an iceberg table rollback using Pyiceberg

3 weeks ago 13
ARTICLE AD BOX

I am trying to write lambda code that executes a rollback on an incerbg table using time travel.

My goal is to pass a table name and a timestamp in order to execute a time travel + overwrite so that my table gets back to its previous state.

I cant find the good code for that.

I am able to list all snapshots using

table = catalog.load_table('db.table') s = table.current_snapshot()

and then, load a specific snapshot:

table.snapshot_by_id(XXXX)

What should I do next to execute a rollback to the snapshot ? (By id or by timestamp Im just looking to understand the logic of it.

Read Entire Article