qds-sdk

import os from qds_sdk.commands import HiveCommand from qds_sdk import qds # Configure Qubole API token and endpoint qds.set_api_token(os.environ.get('QDS_API_TOKEN', '')) qds.set_api_url(os.environ.get('QDS_API_URL', 'https://api.qubole.com/api/v1.2')) # Define and execute a Hive command hive_command = HiveCommand.create( query='SELECT 1 + 1 AS result;', cluster_id=os.environ.get('QDS_CLUSTER_ID', None) # Use an existing cluster ID or name ) print(f"Submitted Hive Command ID: {hive_command.id}") # Wait for command completion (optional, for synchronous execution) status = HiveCommand.wait_for_completion(hive_command.id) print(f"Command {hive_command.id} finished with status: {status}") # Fetch results if status == 'done': result = HiveCommand.get_results(hive_command.id) print("Query Result:") print(result)