kenken999 commited on
Commit
20c5a04
1 Parent(s): 5b122f8
babyagi/classesa/diamond.py CHANGED
@@ -61,7 +61,62 @@ class ProductDatabase:
61
  limit 10000000
62
  """, (query_vector, top_k))
63
  results = cursor.fetchall()
64
- return results
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
65
 
66
  def calculate(query):
67
  # データベース接続情報
 
61
  limit 10000000
62
  """, (query_vector, top_k))
63
  results = cursor.fetchall()
64
+ return results
65
+
66
+ def create_index():
67
+ # データベース接続情報
68
+ DATABASE_URL = "postgresql://miyataken999:[email protected]/neondb?sslmode=require"
69
+
70
+ # ProductDatabaseクラスのインスタンスを作成
71
+ db = ProductDatabase(DATABASE_URL)
72
+
73
+ # データベースに接続
74
+ db.connect()
75
+
76
+ try:
77
+ # pgvector拡張機能のインストールとカラムの追加
78
+ db.setup_vector_extension_and_column()
79
+ print("Vector extension installed and column added successfully.")
80
+ query_text="1"
81
+ results = db.search_similar_all(query_text)
82
+ print("Search results:")
83
+ DEBUG=1
84
+ if DEBUG==1:
85
+ for result in results:
86
+ print(result)
87
+ id = result[0]
88
+ sample_text = str(result[1])+str(result[2])+str(result[3])+str(result[4])+str(result[5])+str(result[6])+str(result[7])+str(result[8])+str(result[9])
89
+ print(sample_text)
90
+ db.insert_vector(id, sample_text)
91
+ #return
92
+ # サンプルデータの挿入
93
+ #sample_text = """"""
94
+ #sample_product_id = 1 # 実際の製品IDを使用
95
+ #db.insert_vector(sample_product_id, sample_text)
96
+ #db.insert_vector(2, sample_text)
97
+
98
+ #print(f"Vector inserted for product ID {sample_product_id}.")
99
+
100
+
101
+ # ベクトル検索
102
+ query_text = "2.03Very GoodJSI262.058.08.068.125.05"
103
+
104
+ query_text = "2.03Very GoodJSI2"
105
+ #query
106
+
107
+ #query_text = "2.03-Very Good-J-SI2-62.2-58.0-7.27-7.33-4.55"
108
+ results = db.search_similar_vectors(query)#query_text)
109
+ res_all = ""
110
+ print("Search results:")
111
+ for result in results:
112
+ print(result)
113
+ res_all += str(result)+"\r\n"
114
+ return res_all
115
+
116
+ finally:
117
+ # 接続を閉じる
118
+ db.close()
119
+
120
 
121
  def calculate(query):
122
  # データベース接続情報
mysite/routers/fastapi.py CHANGED
@@ -121,6 +121,8 @@ def setup_webhook_routes(app: FastAPI):
121
  ほかに、良い提案があればして下さい。こうしたらもっと、良くなるよなど。
122
  ## リファスタの住所
123
  〒170-0013 東京都豊島区東池袋1丁目25−14 アルファビルディング 4F
 
 
124
  ## 買取テンプレート
125
  ・ブランド名:
126
  ・モデル名:
 
121
  ほかに、良い提案があればして下さい。こうしたらもっと、良くなるよなど。
122
  ## リファスタの住所
123
  〒170-0013 東京都豊島区東池袋1丁目25−14 アルファビルディング 4F
124
+ ## ダイヤテンプレート
125
+ -
126
  ## 買取テンプレート
127
  ・ブランド名:
128
  ・モデル名: