|
| 1 | +""" |
| 2 | +1- veri isimli bir klasör oluştur |
| 3 | +2- zip dosyasını veri klasörüne çıkart |
| 4 | +3- zip dosyası içindeki csv dosyalarının tüm içeriğini tek bir csv dosyasında birleştirin |
| 5 | + volume olmasın |
| 6 | +4- bu kayıtların tamamını sqlite veritabanına bir tablo oluşturarak yükleyin |
| 7 | +5- kullanıcının belirlediği paritenin |
| 8 | + kullanıcının belirlediği aralığın |
| 9 | + kullanıcının belirlediği değerin grafiğini çizdirin (veriler sqlite tan çekilecek) |
| 10 | +""" |
| 11 | +import os |
| 12 | +import zipfile |
| 13 | +import pandas as pd |
| 14 | +import sqlite3 |
| 15 | + |
| 16 | +bag = sqlite3.connect("kripto.vt") |
| 17 | +cursor = bag.cursor() |
| 18 | + |
| 19 | +if not os.path.exists("veri"): |
| 20 | + os.mkdir('veri') |
| 21 | + pariteler = zipfile.ZipFile('pariteler_cikti_1hour_2022_2022.zip') |
| 22 | + pariteler.extractall("veri/") |
| 23 | + |
| 24 | + all_files = os.listdir("veri") |
| 25 | + pandas_csv_listesi = [] |
| 26 | + for csv_dosya in all_files: |
| 27 | + veri = pd.read_csv("veri/" + csv_dosya) |
| 28 | + del veri["volume"] |
| 29 | + veri["parite"] = csv_dosya.split("_")[0] |
| 30 | + pandas_csv_listesi.append(veri) |
| 31 | + |
| 32 | + birlesmis_csv_ler = pd.concat(pandas_csv_listesi) |
| 33 | + |
| 34 | + birlesmis_csv_ler.to_csv('hepsi.csv', index=False) |
| 35 | + cursor.execute("CREATE TABLE IF NOT EXISTS parite(" |
| 36 | + +"id INTEGER PRIMARY KEY AUTOINCREMENT," |
| 37 | + +"parite TEXT, otime TEXT, open FLOAT, " |
| 38 | + +"high FLOAT, low FLOAT, close FLOAT);") |
| 39 | + |
| 40 | + kayitlar = pd.read_csv("hepsi.csv") |
| 41 | + for row in kayitlar.itertuples(): |
| 42 | + cursor.execute("INSERT INTO " |
| 43 | + + "parite(parite,otime,open,high,low,close)" |
| 44 | + + " VALUES(" |
| 45 | + + "'"+row.parite+"'," |
| 46 | + + "'"+row.otime+"'," |
| 47 | + + ""+str(row.open)+"," |
| 48 | + + ""+str(row.high)+"," |
| 49 | + + ""+str(row.low)+"," |
| 50 | + + ""+str(row.close)+")") |
| 51 | + bag.commit() |
| 52 | + |
| 53 | + |
| 54 | +parite = input("Parite Giriniz :") |
| 55 | +bas_tarih = input("Başlangıç Tarihi :") |
| 56 | +bit_tarih = input("Bitiş Tarihi :") |
| 57 | + |
| 58 | +sorgu = "SELECT * FROM parite WHERE " \ |
| 59 | + "(otime BETWEEN '"+bas_tarih+"' " \ |
| 60 | + "AND '"+bit_tarih+"') " \ |
| 61 | + "AND parite='"+parite+"'" |
| 62 | +cursor.execute(sorgu) |
| 63 | +sonuc = cursor.fetchall() |
| 64 | +print(sonuc) |
0 commit comments