LBvnSX3G

1query1 = "CREATE TABLE IF NOT EXISTS table1(artist text, title text, 
2            length text, sessionId text, itemInSession text, PRIMARY KEY (sessionId, title, artist))"     
3
4session.execute(query1) 
5     
6file = 'event_datafile_new.csv'
7
8with open(file, encoding = 'utf8') as f:
9    csvreader = csv.reader(f)
10    next(csvreader) # skip header
11    for line in csvreader:
12        query = "INSERT INTO table1(artist, title, length, sessionId, itemInSession)"
13        query = query + "VALUES(%s, %s, %s, %s, %s)"
14        session.execute(query, (line[0], line[9], line[5], line[8], line[3])) 
15     
16---> 13         session.execute(query, (line[0], line[9], line[5], line[8], line[3]))
17
18/opt/conda/lib/python3.6/site-packages/cassandra/cluster.cpython-36m-x86_64-linux-gnu.so in cassandra.cluster.Session.execute (cassandra/cluster.c:38536)()
19
20/opt/conda/lib/python3.6/site-packages/cassandra/cluster.cpython-36m-x86_64-linux-gnu.so in cassandra.cluster.ResponseFuture.result (cassandra/cluster.c:80834)()
21
22InvalidRequest: Error from server: code=2200 [Invalid query] message="Invalid STRING constant (288.9922) for "length" of type float"