kylinpy

import os from kylinpy import KylinClient # Configure connection details using environment variables for security HOST = os.environ.get('KYLIN_HOST', 'localhost') PORT = os.environ.get('KYLIN_PORT', '7070') USERNAME = os.environ.get('KYLIN_USERNAME', 'ADMIN') PASSWORD = os.environ.get('KYLIN_PASSWORD', 'KYLIN') PROJECT = os.environ.get('KYLIN_PROJECT', 'learn_kylin') try: # Initialize the KylinClient client = KylinClient( host=HOST, port=PORT, username=USERNAME, password=PASSWORD ) # Select the project context for operations client.use_project(PROJECT) print(f"Connected to Kylin at {HOST}:{PORT}, project: {PROJECT}") # Execute a sample query and get results as a pandas DataFrame sql_query = "SELECT LSTG_FORMAT_NAME, sum(PRICE) FROM KYLIN_SALES GROUP BY LSTG_FORMAT_NAME ORDER BY sum(PRICE) DESC LIMIT 5" df = client.query_to_dataframe(sql_query) print("\nQuery Results (top 5 rows):") print(df.to_string()) except Exception as e: print(f"An error occurred: {e}") print("Please ensure KYLIN_HOST, KYLIN_PORT, KYLIN_USERNAME, KYLIN_PASSWORD, and KYLIN_PROJECT environment variables are correctly set or provide valid defaults.")