This repository was archived by the owner on Jun 8, 2026. It is now read-only.
Repository navigation
This repository was archived by the owner on Jun 8, 2026. It is now read-only.
Decode metadata and values of PartialResultSet #1316
Description
Activity
@xxntti3n It is highly recommended that you just use the standard query functions in the client library. These already use the
execute_streaming_sqlRPC under the hood and hide the details of mapping the returnedPartialResultSetsand metadata into easy-to-consume objects. So just follow this example:python-spanner/samples/samples/snippets.py
Line 661 in b3c259d
Note that if you specifically want to access the underlying protobuf values instead of having them converted to Python types, then you can set the
lazy_decodingargument like this:with database.snapshot() as snapshot: results = snapshot.execute_sql( "SELECT SingerId, AlbumId, AlbumTitle FROM Albums", lazy_decode=True )
Hello everyone,
I am reading the change stream from Spanner using the Spanner client. I attempted to use StreamedResultSet, but I'm having trouble resolving it. Could someone please help me with mapping the metadata and values from the results when I run execute_streaming_sql? Thank you!
request = spanner_v1.ExecuteSqlRequest( session=session.name, sql=f"SELECT * FROM READ_spanner_all_change_stream( start_timestamp => '{current_time}', end_timestamp => NULL, partition_token => NULL, heartbeat_milliseconds => 10000)", ) result_set = spanner_client.execute_streaming_sql(request=request)