Get Row note data

etl/src/birdxplorer_etl/lib/sqlite/init.py

@@ -3,15 +3,23 @@
 from sqlalchemy.orm import sessionmaker
 import os
 from prefect import get_run_logger
-from birdxplorer_common.storage import Row
+from birdxplorer_common.storage import RowNoteRecord
+from sqlalchemy import inspect
 
 def init_db():
     logger = get_run_logger()
 
+    # ToDo: dbファイルをS3など外部に置く必要がある。
     db_path = os.path.abspath(os.path.join(os.path.dirname(__file__), '..', '..', '..', 'data', 'note.db'))
     logger.info(f'Initializing database at {db_path}')
     engine = create_engine('sqlite:///' + db_path)
-    Base.metadata.create_all(engine)
+
+    # 一時データベースのテーブル作成する
+    # ToDo: noteテーブル以外に必要なものを追加
+    if not inspect(engine).has_table('note'):
+        logger.info('Creating table note')
+        RowNoteRecord.metadata.create_all(engine)
+
     Session = sessionmaker(bind=engine)
 
     return Session()