AWS QLDB ion_document 更新

Question

我有使用部分 SQL 和 ion 文档将数据插入 AWS QLDB 的代码。现在想 update QLDB 里面的一个文件，我找不到任何关于它的例子。请帮忙！

statement = 'INSERT INTO MY_TABLE'
ion_documents = loads(dumps(MY_JSON_DATA))

def query_lambda(tx_executor, query=statement, docs=ion_documents):
    return tx_executor.execute_statement(query, [docs])

def retry_lambda():
    print ('Retrying')

cursor = session.execute_lambda(query_lambda, retry_lambda)

Answer 1

正如您所注意到的，您需要使用 PartiQL 语句来更新文档。您必须插入文档的代码片段是您更新文档所需的大部分内容：您唯一需要做的更改是您正在执行的语句。

该文档有一个 Python 教程，其中包括更新文档的示例：https://docs.aws.amazon.com/qldb/latest/developerguide/getting-started.python.step-5.html。

例如（来自上面的 link），以下将更新示例应用程序中的车主：

def update_vehicle_registration(transaction_executor, vin, document_id):
    statement = "UPDATE VehicleRegistration AS r SET r.Owners.PrimaryOwner.PersonId = ? WHERE r.VIN = ?"
    parameters = [document_id, convert_object_to_ion(vin)]
    cursor = transaction_executor.execute_statement(statement, parameters)
    try:
        print_result(cursor)
        logger.info('Successfully transferred vehicle with VIN: {} to new owner.'.format(vin))
    except StopIteration:
        raise RuntimeError('Unable to transfer vehicle, could not find registration.')

注意使用 ? 作为绑定参数。这些将绑定到传递给 execute_statement 的第二个参数的值（以相应的顺序）。

以下是有关 PartiQL 更新语句的一些信息：https://docs.aws.amazon.com/qldb/latest/developerguide/ql-reference.update.html。语法是：

UPDATE table [ AS table_alias ] [ BY id_alias ]
SET element = data [, element = data, ... ]
[ WHERE condition ]

运行更新语句的结果将是受更新影响的文档 ID。

AWS QLDB ion_document 更新

AWS QLDB ion_document update

python

amazon-qldb