將列當成一個原子計數器使用,對該列進行原子計數操作,可用於為某些線上應用提供即時統計功能,例如統計文章的PV(即時瀏覽量)等。

说明 從Python SDK 5.1.0以上版本開始支援原子計數器功能。

前提條件

  • 已初始化Client,詳情請參見初始化
  • 已建立資料表並寫入資料。

限制

  • 只支援對整型列的列值進行原子計數操作。
  • 作為原子計數器的列,如果寫入資料前該列不存在,則預設值為0;如果寫入資料前該列已存在且列值非整型,則產生OTSParameterInvalid錯誤。
  • 增量值可以是正數或負數,但不能出現計算溢出。如果出現計算溢出,則產生OTSParameterInvalid錯誤。
  • 預設不返回進行原子計數操作的列值,可以通過相應操作指定返回進行原子計數操作的列值。
  • 在單次更新要求中,不能對某一列同時進行更新和原子計數操作。假設列A已經執行原子計數操作,則列A不能再執行其他動作(例如列的覆蓋寫,列刪除等)。
  • 在一次BatchWriteRow請求中,支援對同一行進行多次更新操作。但是如果某一行已進行原子計數操作,則該行在此批量請求中只能出現一次。
  • 原子計數操作只能作用在列值的最新版本,不支援對列值的特定版本做原子計數操作。更新完成後,原子計數操作會插入一個新的資料版本。

介面

updateRow介面新增了原子計數器的相關操作,操作說明請參見下表。
操作 說明
update_of_attribute_columns 更新類型為INCREMENT,對列執行增量變更,例如+X,-X等。

參數

參數 說明
table_name 資料表名稱。
column_name 進行原子計數操作的列名。只支援對整型列的列值進行原子計數器操作。
value 對列進行增量變更的值。

樣本

寫入資料時,使用updateRow介面對整型列做列值的增量變更,屬性列中對應類型為INCREMENT。
def increment_by_update_row(client):
    primary_key = [('pk0', 1)]
    # INCREMENT類型為自增列,如下樣本對price屬性列值+6。
    update_of_attribute_columns = {
        'INCREMENT': [('price', 6)]
    }
    row = Row(primary_key, update_of_attribute_columns)
    consumed, return_row = client.update_row(table_name, row, None)
    print ('Update succeed, consume %s write cu.' % consumed.write)