StreamCursor Reference

class pyqldb.cursor.stream_cursor.StreamCursor(statement_result, session, transaction_id)[source]

An iterable class representing a stream cursor on a statement’s result set.

Parameters
  • statement_result (dict) – The initial result set data dictionary of the statement execution.

  • session (pyqldb.communication.session_client.SessionClient) – The parent session that represents the communication channel to QLDB.

  • transaction_id (str) – The ID of this cursor’s parent transaction, required to fetch pages.

close()[source]

Close this stream cursor object.

get_consumed_ios()[source]

Return a dictionary containing the accumulated amount of IO requests for a statement execution. Return None if there were no read IOs for a statement execution.

Return type

dict/None

Returns

The amount of read IO requests for a statement execution.

get_timing_information()[source]

Return a dictionary containing the accumulated amount of processing time for a statement execution. Return None if there was no timing information for a statement execution.

Return type

dict/None

Returns

The amount of processing time in milliseconds for a statement execution.