SQLAlchemyカスタムタイプの元の値を取得する方法は？

Question

私の質問は短く： SQLAlchemyのカスタムタイプの元の値にアクセスすることは可能ですか？

カスタムタイプの私の実装：

class JSONDocument(TypeDecorator): 
    # override field 
    impl = JSON 

    # Write 
    def process_bind_param(self, value, dialect): 
     if value is not None: 
      req = requests.post(url, data=json.dumps({'data': value})) 
      uri = req.json()['uri'] 
      value = uri 
     return value 

    # Read 
    def process_result_value(self, value, dialect): 
     if value is not None: 
      uri = value 
      req = requests.get(uri) 
      value = req.json()['data'] 
     return value 

私のテーブルモデル：

class SomeTable(db.Model): 
    id = db.Column(db.Integer, primary_key=True) 
    # The column with large json data 
    json_data = db.Column(JSONDocument) 

私は結果としてjson_data欄に書き込みます行を更新または挿入しようとするたびに、 SQLAlchemyはJSONDocumentのprocess_bind_paramを呼び出します。次に、NoSQLテーブルに新しいデータエントリを作成し、SQLテーブル内のjson_dataカラムを返されたURIに更新するPOST APIコールを行います。

json_data列にアクセスしようとするたびに、SQLテーブルに格納されているURIへのGET APIコールが実行され、NoSQLテーブルに格納されている実際のJSONデータが返されます。

私の質問：JSONDocumentでカバーされたSQLテーブルに格納されたURIを取得するにはどうすればよいですか？私はjson_dataを更新するたびに、古いURIへのDELETE API呼び出しを行いたいと思います。

SQLAlchemyのマッピングイベントコールバックを使用しようとしましたが、自分のカスタムタイプの背後にURIを取得できません。

私の質問を十分に聞いていないかどうか教えてください。任意の提案やアイデアが評価されます。

私がやろうとしていたタスクの概要：

私はPostgreSQLデータベース列があります（RDS）のテーブルがあります：id（int型）、json_data（文字列）、other_columnsを...

json_dataのカラムがストレージを大量に占有しているため、そのカラムのデータを他のNoSQLデータベース（DynamoDB）に移動する作業をしています。私はNoSQLテーブルのデータを更新、挿入、およびソフト削除するためのRESTfulなAPIサーバを実装しました。

私のアプリが他のPythonコードのjson_data列にアクセスしようとするたびにAPIメソッドを自動的に呼び出すSQLAlchemyカスタムタイプを実装したいと思います。

Answer 1

カスタムTypeDecoratorを削除し、プロパティを使用してこれと同様のSomeTableにロジックを移動することについてはありますか？

class SomeTable(db.Model): 
    id = db.Column(db.Integer, primary_key=True) 
    # The column with large json data 
    _uri = db.Column(db.JSON) 

    @property 
    def json_data(self): 
     if self._uri is not None: 
      req = requests.get(self._uri) 
      return req.json()['data'] 
     else: 
      return None 

    @json_data.setter 
    def json_data(self, value): 
     req = requests.post(url, data=json.dumps({'data': value})) 
     self._uri = req.json()['uri'] 

    @property 
    def uri(self): 
     return self._uri