分布式事务服务年末活动

class OrderSaga:
    def __init__(self):
        self.steps = []

    def add_step(self, action, compensation):
        self.steps.append((action, compensation))

    def execute(self):
        compensations = []
        try:
            for action, _ in self.steps:
                action()
                compensations.append(_)
        except Exception as e:
            for compensation in reversed(compensations):
                compensation()
            raise e

# 使用示例
def create_order():
    print("Creating order...")
    # 实际逻辑...

def cancel_order():
    print("Canceling order...")
    # 实际逻辑...

def reserve_inventory():
    print("Reserving inventory...")
    # 实际逻辑...

def release_inventory():
    print("Releasing inventory...")
    # 实际逻辑...

saga = OrderSaga()
saga.add_step(create_order, cancel_order)
saga.add_step(reserve_inventory, release_inventory)

saga.execute()