denis_gribanov
11/14/2023, 9:24 AMNotImplementedError
. The error appears after initializing one of the streams: Initializing target sink for stream 'my_stream'
.
Is it a memory issue? Or it has something to do with data types (the records itself are small)?
Example of a record from the stream:
{"type": "RECORD", "stream": "my_stream", "record": {"id": "my_value", "provider_transaction_id": my_value, "amount": my_value, "datetime": "my_value", "meta": {"data": "{\"my_value\":{\"my_value\":{\"my_value\":true,\"my_value\":\"my_value\",\"amount\":my_value,\"currency\":\"my_value\",\"period\":1,\"accountId\":\"my_value\"}},\"my_value\":my_value,\"my_value\":\"my_value\",\"accountId\":\"my_value\",\"invoiceId\":\"my_value\",\"invoice\":\"my_value\",\"amount\":my_value,\"description\":\"my_value\",\"productId\":\"my_value\",\"months\":1,\"currency\":\"my_value\"}", "email": "my_value", "token": "my_value", "IpCity": "my_value", "Issuer": "my_value", "Status": "Authorized", "IpRegion": "my_value", "IpAddress": "my_value", "IpCountry": "my_value", "auth_code": "my_value", "total_fee": my_value, "IpDistrict": "my_value", "IpLatitude": "my_value", "IpLongitude": "my_value", "card_product": "my_value", "gateway_name": "my_value", "payment_amount": my_value, "transaction_id": my_value, "payment_currency": "my_value", "IssuerBankCountry": "my_value", "fall_back_scenario_declined_transaction_id": null}, "currency": "my_value", "invoice_id": "my_value", "description": "my_value", "subscription_id": "my_value", "payment_method": "", "account_id": my_value, "test_mode": false, "operation_type": "my_value", "card_owner_name": "", "card_first_six": "my_value", "card_last_four": "my_value", "card_exp_date": "my_value", "card_type": "my_value", "product_id": "my_value", "months": my_value, "product_type": "my_value", "status": null, "updated_at": "2023-09-28T15:13:29.631524"}, "time_extracted": "2023-11-14T09:09:28.338421+00:00"}
denis_gribanov
11/14/2023, 9:58 AMmy_stream:
meta:
type: [object, "null"]
visch
11/14/2023, 10:56 AM