I’m getting these errors, and i’ dont know how to fix.
The code is a Chart, its using the tradingview lightweight charts. Its basicly generating itself some
price and some other datas and making a “stock” chart.
I’m saving the data to a mysql server, but when i wanna to load the data i’m getting kinda stucked.
Can somebody help?
error:
connection handler failed
Traceback (most recent call last):
File “C:UsersdudasAppDataLocalProgramsPythonPython39libsite-packageswebsocketslegacyserver.py”, line 236, in handler
await self.ws_handler(self)
File “C:UsersdudasAppDataLocalProgramsPythonPython39libsite-packageswebsocketslegacyserver.py”, line 1175, in _ws_handler
return await cast(
File “C:xampphtdocschartprice.py”, line 32, in server
price = result[close]
NameError: name ‘close’ is not defined
import asyncio
import websockets
import random
from datetime import datetime, timedelta
import json
import mysql.connector
# Establishing a database connection
cnx = mysql.connector.connect(user='root', password='',
host='localhost',
database='tradewisedb')
cursor = cnx.cursor()
# Creating the data table if it doesn't exist
cursor.execute("""
CREATE TABLE IF NOT EXISTS prices (
time BIGINT,
open FLOAT,
high FLOAT,
low FLOAT,
close FLOAT
)
""")
# Simulation parameters
price = 100.0
trend = 1
volatility = 0.02
min_price = 50.0
max_price = 150.0
fluctuation_range = 0.02
post_jump_fluctuation = 0.005
interval = timedelta(minutes=1)
async def server(websocket, path):
cursor.execute("SELECT close FROM prices ORDER BY time DESC LIMIT 1")
result = cursor.fetchone()
if result is not None:
price = result[close]
min_price = result[low]
max_price = result[high]
else:
price = 100.0
trend = 1
volatility = 0.02
min_price = 50.0
max_price = 150.0
fluctuation_range = 0.02
post_jump_fluctuation = 0.005
interval = timedelta(minutes=1) # Fetch previous data from the database
cursor.execute("SELECT * FROM prices ORDER BY time ASC LIMIT 1000")
rows = cursor.fetchall()
previous_data = [{
'time': row[0],
'open': row[1],
'high': row[2],
'low': row[3],
'close': row[4]
} for row in rows]
await websocket.send(json.dumps(previous_data))
while True:
start_time = datetime.now()
open_price = price
high_price = price
low_price = price
start_time_timestamp = int(start_time.timestamp() * 1000) # UNIX timestamp in milliseconds
while datetime.now() - start_time < interval:
# Random 'news' events
if random.random() < 0.01:
trend *= -1
volatility = fluctuation_range
# After a big jump, create some sideways movement
else:
volatility = post_jump_fluctuation
# Random 'market' fluctuations
price *= 1 + trend * volatility * random.uniform(-1, 1)
# Ensure price stays within min and max limits
if price > max_price:
price = max_price
trend = -1
elif price < min_price:
price = min_price
trend = 1
high_price = max(high_price, price)
low_price = min(low_price, price)
temp_data = {
"time": start_time_timestamp,
"open": open_price,
"high": high_price,
"low": low_price,
"close": price
}
await websocket.send(json.dumps(temp_data))
await asyncio.sleep(1)
close_price = price
data = {
"time": start_time_timestamp,
"open": open_price,
"high": high_price,
"low": low_price,
"close": close_price
}
await websocket.send(json.dumps(data))
# Inserting data into the database
add_price = ("INSERT INTO prices "
"(time, open, high, low, close) "
"VALUES (%s, %s, %s, %s, %s)")
cursor.execute(add_price, (data['time'], data['open'], data['high'], data['low'], data['close']))
cnx.commit()
start_server = websockets.serve(server, 'localhost', 8000)
asyncio.get_event_loop().run_until_complete(start_server)
asyncio.get_event_loop().run_forever()
# Closing the database connection
cursor.close()
cnx.close()
Like almost everything what i was know to try.
