FilesExpand file tree

main

/

query_execute.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

13 lines (10 loc) · 436 Bytes

main

/

query_execute.py

Copy path

Top

File metadata and controls

• Code
• Blame

13 lines (10 loc) · 436 Bytes

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

from databricks import sql

import os

with sql.connect(server_hostname = os.getenv("DATABRICKS_SERVER_HOSTNAME"),

http_path = os.getenv("DATABRICKS_HTTP_PATH"),

access_token = os.getenv("DATABRICKS_TOKEN")) as connection:

with connection.cursor() as cursor:

cursor.execute("SELECT * FROM default.diamonds LIMIT 2")

result = cursor.fetchall()

for row in result:

print(row)