Comment décoder l'ion_binaire d'Amazon QLDB en ruby ?

Question

Je jouais avec QLDB d'Amazon avec ruby et a utilisé le aws-sdk-qldb y aws-sdk-qldbsession pierre précieuse. J'obtenais le résultat IonBinary. Mais je ne suis pas en mesure de le décoder et de l'analyser.

Voici le code

      cred = Aws::Credentials.new(ENV['AWS_ACCESS_KEY'], ENV['AWS_SECRET_ACCESS_KEY'])

      qldb_session_client = Aws::QLDBSession::Client.new(region: 'ap-southeast-1', credentials: cred)

      start_session_req = Aws::QLDBSession::Types::StartSessionRequest.new
      start_session_req.ledger_name = 'ledger-test'

      command_request = Aws::QLDBSession::Types::SendCommandRequest.new

      command_request.start_session = start_session_req

      resp = qldb_session_client.send_command(command_request)
      session_token = resp.start_session.session_token

      command_request = Aws::QLDBSession::Types::SendCommandRequest.new
      command_request.session_token = session_token
      command_request.start_transaction = Aws::QLDBSession::Types::StartTransactionRequest.new
      resp = qldb_session_client.send_command(command_request)
      transaction_id = resp.start_transaction.transaction_id

      command_request = Aws::QLDBSession::Types::SendCommandRequest.new
      command_request.session_token = session_token
      command_request.execute_statement = Aws::QLDBSession::Types::ExecuteStatementRequest.new
      command_request.execute_statement.transaction_id = transaction_id
      command_request.execute_statement.statement = 'select * from testing'

      resp = qldb_session_client.send_command(command_request)

Maintenant, si j'utilise le code suivant

resp.execute_statement.first_page.values[0]

Je reçois

{:ion_binary=>"\xE0\x01\x00\xEA\xEE\x9A\x81\x83\xDE\x96\x87\xBE\x93\x89firstname\x88lastname\xDE\x9D\x8A\x8Dtesting first\x8B\x8Ctesting last", :ion_text=>"[FILTERED]"}

Je ne suis pas capable de décoder cet ion_binaire en utilisant l'analyseur binaire.

Answer 1

Le décodage du flux est susceptible d'être effectué à l'aide de Aws::EventStream::Decoder#decode . Cela dit, un peu comme ci-dessous devrait fonctionner.

Aws::EventStream::Decoder.new.decode(
  StringIO.new(result[:ion_binary])
)