|
import gradio as gr |
|
from huggingface_hub import InferenceClient |
|
import os |
|
from smolagents import tool, CodeAgent, HfApiModel, GradioUI |
|
from sqlalchemy import ( |
|
create_engine, |
|
MetaData, |
|
Table, |
|
Column, |
|
String, |
|
Integer, |
|
Float, |
|
insert, |
|
inspect, |
|
text, |
|
) |
|
import spaces |
|
|
|
from dotenv import load_dotenv |
|
|
|
engine = create_engine("sqlite:///:memory:") |
|
load_dotenv() |
|
|
|
|
|
|
|
|
|
@spaces.GPU |
|
def dummy(): |
|
pass |
|
|
|
|
|
@tool |
|
def sql_engine_tool(query: str) -> str: |
|
""" |
|
Allows you to perform SQL queries on the table. Returns a string representation of the result. |
|
The table is named 'receipts'. Its description is as follows: |
|
Columns: |
|
- receipt_id: INTEGER |
|
- customer_name: VARCHAR(16) |
|
- price: FLOAT |
|
- tip: FLOAT |
|
|
|
Args: |
|
query: The query to perform. This should be correct SQL. |
|
""" |
|
output = "" |
|
with engine.connect() as con: |
|
rows = con.execute(text(query)) |
|
for row in rows: |
|
output += "\n" + str(row) |
|
return output |
|
|
|
|
|
def init_db(): |
|
|
|
metadata_obj = MetaData() |
|
|
|
def insert_rows_into_table(rows, table, engine=engine): |
|
for row in rows: |
|
stmt = insert(table).values(**row) |
|
with engine.begin() as connection: |
|
connection.execute(stmt) |
|
|
|
table_name = "receipts" |
|
receipts = Table( |
|
table_name, |
|
metadata_obj, |
|
Column("receipt_id", Integer, primary_key=True), |
|
Column("customer_name", String(16), primary_key=True), |
|
Column("price", Float), |
|
Column("tip", Float), |
|
) |
|
metadata_obj.create_all(engine) |
|
|
|
rows = [ |
|
{"receipt_id": 1, "customer_name": "Alan Payne", "price": 12.06, "tip": 1.20}, |
|
{"receipt_id": 2, "customer_name": "Alex Mason", "price": 23.86, "tip": 0.24}, |
|
{ |
|
"receipt_id": 3, |
|
"customer_name": "Woodrow Wilson", |
|
"price": 53.43, |
|
"tip": 5.43, |
|
}, |
|
{ |
|
"receipt_id": 4, |
|
"customer_name": "Margaret James", |
|
"price": 21.11, |
|
"tip": 1.00, |
|
}, |
|
] |
|
insert_rows_into_table(rows, receipts) |
|
with engine.begin() as conn: |
|
print("SELECT test", conn.execute("SELECT * FROM receipts")) |
|
|
|
|
|
if __name__ == "__main__": |
|
init_db() |
|
model = HfApiModel( |
|
model_id="HuggingFaceH4/zephyr-7b-beta", |
|
token=os.getenv("my_first_agents_hf_tokens"), |
|
) |
|
|
|
agent = CodeAgent( |
|
tools=[sql_engine_tool], |
|
|
|
|
|
|
|
model=model, |
|
max_steps=7, |
|
verbosity_level=3, |
|
) |
|
GradioUI(agent).launch() |
|
|