Tablestore:Tulis data

API

"""
Deskripsi: Operasi ini menulis satu baris data. Jumlah unit kapasitas (CUs) yang dikonsumsi oleh operasi ini dikembalikan.
table_name: nama tabel.
row: baris yang akan ditulis, termasuk kolom kunci primer dan kolom atribut.
condition: kondisi yang harus dipenuhi untuk menjalankan operasi. Tablestore memeriksa apakah kondisi terpenuhi sebelum menjalankan operasi. Operasi hanya dijalankan jika kondisi terpenuhi. Parameter condition adalah instance dari kelas tablestore.metadata.Condition.
Dua jenis kondisi didukung: kondisi keberadaan baris dan kondisi nilai kolom. Untuk kondisi keberadaan baris, atur parameter condition ke IGNORE, EXPECT_EXIST, atau EXPECT_NOT_EXIST.
return_type: jenis data yang dikembalikan. Parameter return_type adalah instance dari kelas tablestore.metadata.ReturnType. Hanya kunci primer yang dapat dikembalikan. Dalam kebanyakan kasus, parameter ini digunakan untuk kolom kunci primer auto-increment.
Respons: jumlah CUs yang dikonsumsi oleh operasi dan data baris yang dikembalikan.
consumed: jumlah CUs yang dikonsumsi oleh operasi. Parameter consumed adalah instance dari kelas tablestore.metadata.CapacityUnit.
return_row: data baris yang dikembalikan, yang mungkin mencakup kolom kunci primer dan kolom atribut.
Contoh:
    primary_key = [('gid',1), ('uid',101)]
    attribute_columns = [('name','Mary'), ('mobile',111111111), ('address','City A in China'), ('age',20)]
    row = Row(primary_key, attribute_columns)
    condition = Condition('EXPECT_NOT_EXIST')
    consumed, return_row = client.put_row('myTable', row, condition)
"""
def put_row(self, table_name, row, condition = None, return_type = None, transaction_id = None):

Parameter

Contoh

Sisipkan satu baris data.

# Tentukan nama tabel data.
table_name = '<TABLE_NAME>'

# Kolom kunci primer pertama adalah gid dan nilainya adalah integer 1. Kolom kunci primer kedua adalah uid dan nilainya adalah integer 101.
primary_key = [('gid',1), ('uid',101)]
# Baris berisi lima kolom atribut:
# Kolom atribut pertama adalah name dan nilainya adalah string John. Nomor versi data tidak ditentukan. Sistem menggunakan waktu saat ini sebagai nomor versi data.
# Kolom atribut kedua adalah mobile dan nilainya adalah integer 1390000****. Nomor versi data tidak ditentukan. Sistem menggunakan waktu saat ini sebagai nomor versi data.
# Kolom atribut ketiga adalah address dan nilainya adalah nilai biner China. Nomor versi data tidak ditentukan. Sistem menggunakan waktu saat ini sebagai nomor versi data.
# Kolom atribut keempat adalah female dan nilainya adalah nilai Boolean False. Nomor versi data tidak ditentukan. Sistem menggunakan waktu saat ini sebagai nomor versi data.
# Kolom atribut kelima adalah age dan nilainya adalah 29.7. 1498184687000 ditentukan sebagai nomor versi data.
attribute_columns = [('name','John'), ('mobile',1390000****),('address', bytearray('China', encoding='utf8')),('female', False), ('age', 29.7, 1498184687000)]
# Buat baris menggunakan primary_key dan attribute_columns.
row = Row(primary_key, attribute_columns)

# Tentukan kondisi keberadaan baris yang mengharapkan baris yang ditentukan tidak ada. Jika baris yang ditentukan ada, terjadi kesalahan Condition Update Failed.
condition = Condition(RowExistenceExpectation.EXPECT_NOT_EXIST)
try:
    # Jika Anda tidak menentukan parameter ReturnType saat memanggil metode put_row, nilai parameter return_row adalah None.
    consumed, return_row = client.put_row(table_name, row, condition)

    # Tampilkan jumlah CU tulis yang dikonsumsi oleh permintaan.
    print('put row succeed, consume %s write cu.' % consumed.write)
# Pengecualian client biasanya disebabkan oleh kesalahan parameter atau pengecualian jaringan.
except OTSClientError as e:
    print("put row failed, http_status:%d, error_message:%s" % (e.get_http_status(), e.get_error_message()))
# Pengecualian server biasanya disebabkan oleh kesalahan parameter atau kesalahan pembatasan kecepatan.
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()))                    

Untuk kode contoh lengkap, lihat PutRow@GitHub.

Antarmuka

"""
Deskripsi: Operasi ini memperbarui satu baris data.
table_name: nama tabel.
row: baris yang akan diperbarui, termasuk kolom kunci primer dan kolom atribut. Kolom kunci primer dalam format list. Kolom atribut dalam format dict.
condition: kondisi yang harus dipenuhi untuk menjalankan operasi. Tablestore memeriksa apakah kondisi terpenuhi sebelum menjalankan operasi. Operasi hanya dijalankan jika kondisi terpenuhi. Parameter condition adalah instance dari kelas tablestore.metadata.Condition.
Dua jenis kondisi didukung: kondisi keberadaan baris dan kondisi nilai kolom. Untuk kondisi keberadaan baris, atur parameter condition ke IGNORE, EXPECT_EXIST, atau EXPECT_NOT_EXIST.
return_type: jenis data yang dikembalikan. Parameter return_type adalah instance dari kelas tablestore.metadata.ReturnType. Hanya kunci primer yang dapat dikembalikan. Dalam kebanyakan kasus, parameter ini digunakan untuk kolom kunci primer auto-increment.
Respons: jumlah CUs yang dikonsumsi oleh operasi dan data baris yang dikembalikan.
consumed: jumlah CUs yang dikonsumsi oleh operasi. Parameter consumed adalah instance dari kelas tablestore.metadata.CapacityUnit.
return_row: data baris yang dikembalikan.
Contoh:
    primary_key = [('gid',1), ('uid',101)]
    update_of_attribute_columns = {
        'put' : [('name','Jack'), ('address','City A in China')],
        'delete' : [('mobile', None, 1493725896147)],
        'delete_all' : [('age')],
        'increment' : [('counter', 1)]
    }
    row = Row(primary_key, update_of_attribute_columns)
    condition = Condition('EXPECT_EXIST')
    consumed = client.update_row('myTable', row, condition)
"""
def update_row(self, table_name, row, condition, return_type = None, transaction_id = None):

Parameter

Contoh

Perbarui satu baris data.

# Tentukan nama tabel data.
table_name = '<TABLE_NAME>'

# Kolom kunci primer pertama adalah gid dan nilainya adalah integer 1. Kolom kunci primer kedua adalah uid dan nilainya adalah integer 101.
primary_key = [('gid',1), ('uid',101)]
# Pembaruan mencakup tiga bagian: PUT, DELETE, dan DELETE_ALL.
# PUT: menambahkan kolom atribut atau memperbarui nilai yang ada dalam kolom atribut. Dalam contoh ini, dua kolom atribut ditambahkan. Kolom pertama adalah name dan nilainya adalah David. Kolom kedua adalah address dan nilainya adalah Hongkong.
# DELETE: menghapus versi tertentu (stempel waktu) dari data. Dalam contoh ini, data dengan nomor versi data 1488436949003 di kolom address dihapus.
# DELETE_ALL: menghapus kolom. Dalam contoh ini, semua versi data di kolom mobile dan age dihapus.
update_of_attribute_columns = {
    'PUT' : [('name','David'), ('address','Hongkong')],
    'DELETE' : [('address', None, 1488436949003)],
    'DELETE_ALL' : [('mobile'), ('age')],
}
row = Row(primary_key, update_of_attribute_columns)

# Atur kondisi keberadaan baris ke RowExistenceExpectation.IGNORE. Artinya, baris diperbarui terlepas dari apakah baris tersebut ada atau tidak.
condition = Condition(RowExistenceExpectation.IGNORE, SingleColumnCondition("age", 20, ComparatorType.EQUAL)) # perbarui baris hanya jika baris ini ada
try:
    consumed, return_row = client.update_row(table_name, row, condition)
    
    # Tampilkan jumlah CU tulis yang dikonsumsi oleh permintaan.
    print('put row succeed, consume %s write cu.' % consumed.write)
# Pengecualian client biasanya disebabkan oleh kesalahan parameter atau pengecualian jaringan.
except OTSClientError as e:
    print("update row failed, http_status:%d, error_message:%s" % (e.get_http_status(), e.get_error_message()))
# Pengecualian server biasanya disebabkan oleh kesalahan parameter atau kesalahan pembatasan kecepatan.
except OTSServiceError as e:
    print("update 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()))

Untuk kode contoh lengkap, lihat UpdateRow@GitHub.

Catatan Penggunaan

Saat Anda memanggil operasi BatchWriteRow, beberapa baris mungkin gagal ditulis. Operasi ini tidak melemparkan pengecualian untuk kegagalan parsial tersebut. Sebaliknya, BatchWriteRowResponse yang dikembalikan berisi indeks dan pesan kesalahan untuk baris yang gagal. Oleh karena itu, Anda harus memeriksa nilai kembali untuk menentukan apakah setiap baris berhasil ditulis. Jika Anda tidak memeriksa nilai kembali, operasi yang gagal tersebut mungkin terlewatkan.

Jika server mendeteksi kesalahan parameter pada beberapa operasi, operasi BatchWriteRow mungkin melemparkan pengecualian kesalahan parameter. Dalam kasus ini, tidak ada operasi dalam permintaan yang dijalankan.

Contoh

Tulis beberapa baris data.

put_row_items = []
# Tambahkan baris untuk operasi PutRow.
for i in range(0, 20):
    primary_key = [('gid',i), ('uid',i+1)]
    attribute_columns = [('name','somebody'+str(i)), ('address','somewhere'+str(i)), ('age',i)]
    row = Row(primary_key, attribute_columns)
    condition = Condition(RowExistenceExpectation.IGNORE)
    item = PutRowItem(row, condition)
    put_row_items.append(item)

# Tambahkan baris untuk operasi UpdateRow.
for i in range(0, 10):
    primary_key = [('gid',i), ('uid',i+1)]
    attribute_columns = {'put': [('name','somebody'+str(i)), ('address','somewhere'+str(i)), ('age',i)]}
    row = Row(primary_key, attribute_columns)
    condition = Condition(RowExistenceExpectation.IGNORE, SingleColumnCondition("age", i, ComparatorType.EQUAL))
    item = UpdateRowItem(row, condition)
    put_row_items.append(item)

# Tambahkan baris untuk operasi DeleteRow.
delete_row_items = []
for i in range(10, 20):
    primary_key = [('gid',i), ('uid',i+1)]
    row = Row(primary_key)
    condition = Condition(RowExistenceExpectation.IGNORE)
    item = DeleteRowItem(row, condition)
    delete_row_items.append(item)

# Buat permintaan untuk menulis beberapa baris data sekaligus.
request = BatchWriteRowRequest()
request.add(TableInBatchWriteRowItem('<TABLE_NAME>', put_row_items))
request.add(TableInBatchWriteRowItem('<DELETE_TABLE_NAME>', delete_row_items))

# Panggil metode batch_write_row untuk menulis beberapa baris data sekaligus. Jika terjadi kesalahan seperti kesalahan parameter permintaan, pengecualian dilemparkan. Jika beberapa baris gagal, tidak ada pengecualian yang dilemparkan, tetapi item internal mungkin gagal.
try:
    result = client.batch_write_row(request)
    print('Result status: %s'%(result.is_all_succeed()))

    # Periksa hasil operasi PutRow.
    print('check first table\'s put results:')
    succ, fail = result.get_put()
    for item in succ:
        print('Put succeed, consume %s write cu.' % item.consumed.write)
    for item in fail:
        print('Put failed, error code: %s, error message: %s' % (item.error_code, item.error_message))

    # Periksa hasil operasi UpdateRow.
    print('check first table\'s update results:')
    succ, fail = result.get_update()
    for item in succ:
        print('Update succeed, consume %s write cu.' % item.consumed.write)
    for item in fail:
        print('Update failed, error code: %s, error message: %s' % (item.error_code, item.error_message))

    # Periksa hasil operasi DeleteRow.
    print('check second table\'s delete results:')
    succ, fail = result.get_delete()
    for item in succ:
        print('Delete succeed, consume %s write cu.' % item.consumed.write)
    for item in fail:
        print('Delete failed, error code: %s, error message: %s' % (item.error_code, item.error_message)) 
# Pengecualian client biasanya disebabkan oleh kesalahan parameter atau pengecualian jaringan.
except OTSClientError as e:
    print("get row failed, http_status:%d, error_message:%s" % (e.get_http_status(), e.get_error_message()))
# Pengecualian server biasanya disebabkan oleh kesalahan parameter atau kesalahan pembatasan kecepatan.
except OTSServiceError as e:
    print("get 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()))

Untuk kode contoh lengkap, lihat BatchWriteRow@GitHub.