Tablestore：局部事務

前提條件

• 已初始化Client，詳情請參見初始化OTSClient。

• 已建立資料表並寫入資料。

使用方法

1. 使用start_local_transaction在指定的分區索引值建立一個局部事務，並擷取局部事務ID。

2. 對局部事務範圍內的資料進行讀寫操作。

   支援對局部事務進行操作的介面為GetRow、PutRow、DeleteRow、UpdateRow、BatchWriteRow和GetRange。

3. 使用commit_transaction提交局部事務或者使用abort_transaction丟棄局部事務。

注意事項

• 主鍵自增列功能和局部事務功能不能同時使用。

• 局部事務通過悲觀鎖（Pessimistic Lock）實現並發控制。

• 每個局部事務從建立開始生命週期最長為60秒。

  如果超過60秒未提交局部事務或丟棄局部事務，則Table Store服務端會認為此局部事務逾時，並將局部事務丟棄。

• 如果建立局部事務時逾時，則請求可能在Table Store服務端已執行成功，此時請等待該局部事務逾時後重新建立。

• 未提交的局部事務可能會失效，如果出現此情況，則需要重試該局部事務內的操作。

• 如果未對局部事務範圍內的資料進行寫操作，則提交局部事務或丟棄局部事務的操作是等同的。

• 在局部事務中讀寫資料有如下限制：

  • 不能使用局部事務ID訪問局部事務範圍（即建立時使用的分區索引值）以外的資料。

  • 同一個局部事務中所有寫請求的分區索引值必須與建立局部事務時的分區索引值相同，讀請求則無此限制。

  • 一個局部事務同時只能用於一個請求中，在使用局部事務期間，其他使用此局部事務ID的操作均會失敗。

  • 每個局部事務中兩次讀寫操作的最大間隔為60秒。

    如果超過60秒未操作局部事務，則Table Store服務端會認為此局部事務逾時，並將局部事務丟棄。

  • 每個局部事務中寫入的資料量最大為4 MB，按正常的寫請求資料量計算規則累加。

  • 如果在局部事務中寫入了未指定版本號碼的Cell，則該Cell的版本號碼會在寫入資料時（而非提交局部事務時）由Table Store服務端自動產生，建置規則與正常寫入一個未指定版本號碼的Cell相同。

  • 如果BatchWriteRow請求中帶有局部事務ID，則此請求中所有行只能操作該局部事務ID對應的表。

  • 在使用局部事務期間，對應分區索引值的資料會被加上寫鎖，只有持有局部事務ID在局部事務範圍內的寫請求才會成功。其他非事務請求或持有其他局部事務ID在局部事務範圍內的寫請求均會失敗。在局部事務提交、丟棄或逾時後，對應的鎖也會被釋放。

  • 帶有局部事務ID的讀寫請求失敗不會影響局部事務本身的存活情況，您可以指定重試規則進行重試或者主動丟棄當前局部事務。

參數

樣本

def  transaction_put_row(client):
    # 設定資料表名稱。
    table_name = '<TABLE_NAME>'
    # 在PK0下建立局部事務。
    key = [('PK0', 1)]
    # start_local_transaction方法的傳回值即為transaction_id。
    transaction_id = client.start_local_transaction(table_name, key)

    # 寫入資料。
    primary_key = [('PK0', 1), ('PK1', 'transaction')]
    attribute_columns = [('value', 'origion value')]
    row = Row(primary_key, attribute_columns)
    condition = Condition(RowExistenceExpectation.IGNORE)
    try:
        # 調用put_row方法，如果沒有指定ReturnType，則return_row為None。
        consumed, return_row = client.put_row(table_name, row, condition, None, transaction_id)
        # 列印此次請求消耗的寫CU。
        print('put row succeed, consume %s write cu.' % consumed.write)
        # 如果資料寫入成功，則提交事務，使局部事務中的所有資料修改生效。您也可以通過丟棄事務來使資料寫入不生效。
        client.commit_transaction(transaction_id)
    # 用戶端異常，一般為參數錯誤或者網路異常。
    except OTSClientError as e:
        print("put row failed, http_status:%d, error_message:%s" % (e.get_http_status(), e.get_error_message()))
        # 如果資料寫入失敗，則丟棄事務，局部事務中的所有資料修改均不會應用到原有資料。
        client.abort_transaction(transaction_id)
    # 服務端異常，一般為參數錯誤或者流控錯誤。
    except OTSServiceError as e:
        print("put row failed, http_status:%d, error_code:%s, error_message:%s, request_id:%s" % (e.get_http_status(), e.get_error_code(), e.get_error_message(), e.get_request_id())) 
        # 如果資料寫入失敗，則丟棄事務，局部事務中的所有資料修改均不會應用到原有資料。
        client.abort_transaction(transaction_id)

def transaction_get_row(client):
    # 設定資料表名稱。
    table_name ='<TABLE_NAME>'
    # 在PK0下建立局部事務。
    key = [('PK0', 1)]
    # start_local_transaction方法的傳回值即為transaction_id。
    transaction_id = client.start_local_transaction(table_name, key)
    
    # 讀取資料。
    primary_key = [('PK0', 1), ('PK1', 'transaction')]
    columns_to_get = ['value']
    consumed, return_row, next_token = client.get_row(
        table_name, primary_key, columns_to_get, None, 1, None, None, None, None, transaction_id
    )
    for att in return_row.attribute_columns:
        print ('\tname:%s\tvalue:%s' % (att[0], att[1]))

    # 提交或丟棄局部事務。對於讀操作來說，提交局部事務或丟棄局部事務的操作是等同的。
    # 提交局部事務，使局部事務中的所有資料修改生效。
    client.commit_transaction(transaction_id)
    # 丟棄局部事務，局部事務中的所有資料修改均不會應用到原有資料。
    #client.abort_transaction(transaction_id)

相關文檔

如果要在局部事務內進行批量寫入、範圍讀取等操作，請在建立局部事務後，使用寫入資料或者讀取資料文檔中的相應操作樣本以及在請求中帶上局部事務ID實現。