diff --git a/airbyte-integrations/connectors/source-amazon-seller-partner/acceptance-test-config.yml b/airbyte-integrations/connectors/source-amazon-seller-partner/acceptance-test-config.yml index 6e02cebef868..c59cf974ed13 100644 --- a/airbyte-integrations/connectors/source-amazon-seller-partner/acceptance-test-config.yml +++ b/airbyte-integrations/connectors/source-amazon-seller-partner/acceptance-test-config.yml @@ -49,8 +49,6 @@ acceptance_tests: bypass_reason: "Data cannot be seeded in the test account, integration tests added for the stream instead" - name: GET_FBA_FULFILLMENT_CUSTOMER_RETURNS_DATA bypass_reason: "Data cannot be seeded in the test account, integration tests added for the stream instead" - - name: GET_FBA_SNS_FORECAST_DATA - bypass_reason: "Data cannot be seeded in the test account, integration tests added for the stream instead" - name: GET_AFN_INVENTORY_DATA bypass_reason: "Data cannot be seeded in the test account, integration tests added for the stream instead" - name: GET_MERCHANT_CANCELLED_LISTINGS_DATA @@ -69,8 +67,6 @@ acceptance_tests: bypass_reason: "Data cannot be seeded in the test account, integration tests added for the stream instead" - name: GET_VENDOR_INVENTORY_REPORT bypass_reason: "Data cannot be seeded in the test account, integration tests added for the stream instead" - - name: GET_FBA_SNS_PERFORMANCE_DATA - bypass_reason: "Data cannot be seeded in the test account, integration tests added for the stream instead" - name: GET_FBA_ESTIMATED_FBA_FEES_TXT_DATA bypass_reason: "Data cannot be seeded in the test account, integration tests added for the stream instead" - name: GET_FBA_INVENTORY_PLANNING_DATA diff --git a/airbyte-integrations/connectors/source-amazon-seller-partner/erd/discovered_catalog.json b/airbyte-integrations/connectors/source-amazon-seller-partner/erd/discovered_catalog.json index 3577a2c23fb5..507bc1065719 100644 --- a/airbyte-integrations/connectors/source-amazon-seller-partner/erd/discovered_catalog.json +++ b/airbyte-integrations/connectors/source-amazon-seller-partner/erd/discovered_catalog.json @@ -1940,17 +1940,39 @@ "description": "Address details for tax registration.", "type": ["null", "object"], "properties": { - "name": { "type": ["null", "string"] }, - "addressLine1": { "type": ["null", "string"] }, - "addressLine2": { "type": ["null", "string"] }, - "addressLine3": { "type": ["null", "string"] }, - "city": { "type": ["null", "string"] }, - "county": { "type": ["null", "string"] }, - "district": { "type": ["null", "string"] }, - "stateOrRegion": { "type": ["null", "string"] }, - "postalCode": { "type": ["null", "string"] }, - "countryCode": { "type": ["null", "string"] }, - "phone": { "type": ["null", "string"] } + "name": { + "type": ["null", "string"] + }, + "addressLine1": { + "type": ["null", "string"] + }, + "addressLine2": { + "type": ["null", "string"] + }, + "addressLine3": { + "type": ["null", "string"] + }, + "city": { + "type": ["null", "string"] + }, + "county": { + "type": ["null", "string"] + }, + "district": { + "type": ["null", "string"] + }, + "stateOrRegion": { + "type": ["null", "string"] + }, + "postalCode": { + "type": ["null", "string"] + }, + "countryCode": { + "type": ["null", "string"] + }, + "phone": { + "type": ["null", "string"] + } } }, "taxRegistrationMessages": { @@ -2038,17 +2060,39 @@ "description": "Address details for tax registration.", "type": ["null", "object"], "properties": { - "name": { "type": ["null", "string"] }, - "addressLine1": { "type": ["null", "string"] }, - "addressLine2": { "type": ["null", "string"] }, - "addressLine3": { "type": ["null", "string"] }, - "city": { "type": ["null", "string"] }, - "county": { "type": ["null", "string"] }, - "district": { "type": ["null", "string"] }, - "stateOrRegion": { "type": ["null", "string"] }, - "postalCode": { "type": ["null", "string"] }, - "countryCode": { "type": ["null", "string"] }, - "phone": { "type": ["null", "string"] } + "name": { + "type": ["null", "string"] + }, + "addressLine1": { + "type": ["null", "string"] + }, + "addressLine2": { + "type": ["null", "string"] + }, + "addressLine3": { + "type": ["null", "string"] + }, + "city": { + "type": ["null", "string"] + }, + "county": { + "type": ["null", "string"] + }, + "district": { + "type": ["null", "string"] + }, + "stateOrRegion": { + "type": ["null", "string"] + }, + "postalCode": { + "type": ["null", "string"] + }, + "countryCode": { + "type": ["null", "string"] + }, + "phone": { + "type": ["null", "string"] + } } }, "taxRegistrationMessages": { @@ -2837,7 +2881,9 @@ "Component": { "description": "Price components for the item", "type": ["array"], - "items": { "type": ["null", "object"] }, + "items": { + "type": ["null", "object"] + }, "properties": { "Type": { "description": "Type of price component", @@ -3015,7 +3061,9 @@ "attribute": { "description": "List of attributes", "type": ["array"], - "items": { "type": ["null", "object"] }, + "items": { + "type": ["null", "object"] + }, "properties": { "name": { "description": "The name of the attribute", @@ -3064,7 +3112,9 @@ "id": { "description": "The unique identifiers of child nodes", "type": ["array"], - "items": { "type": ["null", "string"] } + "items": { + "type": ["null", "string"] + } } } }, @@ -5733,7 +5783,9 @@ "OrderItem": { "description": "Details about the individual items in the order.", "type": ["array"], - "items": { "type": ["null", "object"] }, + "items": { + "type": ["null", "object"] + }, "properties": { "ItemStatus": { "description": "The status of the order item.", @@ -5750,7 +5802,9 @@ "Component": { "description": "Breakdown of item components if applicable.", "type": ["array"], - "items": { "type": ["null", "object"] }, + "items": { + "type": ["null", "object"] + }, "properties": { "Type": { "description": "The type of item price component.", @@ -5900,99 +5954,6 @@ "source_defined_cursor": true, "default_cursor_field": ["dataEndTime"] }, - { - "name": "GET_FBA_SNS_FORECAST_DATA", - "json_schema": { - "title": "Subscribe and Save Forecast Report", - "description": "", - "type": "object", - "$schema": "http://json-schema.org/draft-07/schema#", - "properties": { - "offer-state": { - "description": "Current state of the offer for the product.", - "type": ["null", "string"] - }, - "snapshot-date": { - "description": "Date and time when the snapshot of the data was taken.", - "type": ["null", "string"], - "format": "date-time" - }, - "sku": { - "description": "Stock Keeping Unit (SKU) for the product.", - "type": ["null", "string"] - }, - "fnsku": { - "description": "Fulfillment Network SKU (FNSKU) for the product.", - "type": ["null", "string"] - }, - "asin": { - "description": "Unique identifier for the ASIN (Amazon Standard Identification Number).", - "type": ["null", "string"] - }, - "estimated-avg-sns-discount-next-8-weeks": { - "description": "Estimated average discount on Subscribe & Save units for the next 8 weeks.", - "type": ["null", "string"] - }, - "product-name": { - "description": "Name of the product associated with the ASIN.", - "type": ["null", "string"] - }, - "country": { - "description": "Country for which the forecast data is applicable.", - "type": ["null", "string"] - }, - "active-subscriptions": { - "description": "Number of active subscriptions for the ASIN in the specified country.", - "type": ["null", "string"] - }, - "week-1-start-date": { - "description": "Start date and time for week 1 of the forecast period.", - "type": ["null", "string"], - "format": "date-time" - }, - "scheduled-sns-units-week-1": { - "description": "Number of scheduled Subscribe & Save units for week 1.", - "type": ["null", "string"] - }, - "scheduled-sns-units-week-2": { - "description": "Number of scheduled Subscribe & Save units for week 2.", - "type": ["null", "string"] - }, - "scheduled-sns-units-week-3": { - "description": "Number of scheduled Subscribe & Save units for week 3.", - "type": ["null", "string"] - }, - "scheduled-sns-units-week-4": { - "description": "Number of scheduled Subscribe & Save units for week 4.", - "type": ["null", "string"] - }, - "scheduled-sns-units-week-5": { - "description": "Number of scheduled Subscribe & Save units for week 5.", - "type": ["null", "string"] - }, - "scheduled-sns-units-week-6": { - "description": "Number of scheduled Subscribe & Save units for week 6.", - "type": ["null", "string"] - }, - "scheduled-sns-units-week-7": { - "description": "Number of scheduled Subscribe & Save units for week 7.", - "type": ["null", "string"] - }, - "scheduled-sns-units-week-8": { - "description": "Number of scheduled Subscribe & Save units for week 8.", - "type": ["null", "string"] - }, - "dataEndTime": { - "description": "End time for the forecast data, indicated in date format.", - "type": ["null", "string"], - "format": "date" - } - } - }, - "supported_sync_modes": ["full_refresh", "incremental"], - "source_defined_cursor": true, - "default_cursor_field": ["dataEndTime"] - }, { "name": "Performance_Data", "json_schema": { @@ -7723,14 +7684,33 @@ "type": ["null", "string"], "format": "date" }, - "asin": { "type": ["null", "string"] }, - "startDate": { "type": ["null", "string"], "format": "date" }, - "endDate": { "type": ["null", "string"], "format": "date" }, - "meanForecastUnits": { "type": ["null", "number"] }, - "p70ForecastUnits": { "type": ["null", "number"] }, - "p80ForecastUnits": { "type": ["null", "number"] }, - "p90ForecastUnits": { "type": ["null", "number"] }, - "dataEndTime": { "type": ["null", "string"], "format": "date" } + "asin": { + "type": ["null", "string"] + }, + "startDate": { + "type": ["null", "string"], + "format": "date" + }, + "endDate": { + "type": ["null", "string"], + "format": "date" + }, + "meanForecastUnits": { + "type": ["null", "number"] + }, + "p70ForecastUnits": { + "type": ["null", "number"] + }, + "p80ForecastUnits": { + "type": ["null", "number"] + }, + "p90ForecastUnits": { + "type": ["null", "number"] + }, + "dataEndTime": { + "type": ["null", "string"], + "format": "date" + } } }, "supported_sync_modes": ["full_refresh"] @@ -7747,14 +7727,33 @@ "type": ["null", "string"], "format": "date" }, - "asin": { "type": ["null", "string"] }, - "startDate": { "type": ["null", "string"], "format": "date" }, - "endDate": { "type": ["null", "string"], "format": "date" }, - "meanForecastUnits": { "type": ["null", "number"] }, - "p70ForecastUnits": { "type": ["null", "number"] }, - "p80ForecastUnits": { "type": ["null", "number"] }, - "p90ForecastUnits": { "type": ["null", "number"] }, - "dataEndTime": { "type": ["null", "string"], "format": "date" } + "asin": { + "type": ["null", "string"] + }, + "startDate": { + "type": ["null", "string"], + "format": "date" + }, + "endDate": { + "type": ["null", "string"], + "format": "date" + }, + "meanForecastUnits": { + "type": ["null", "number"] + }, + "p70ForecastUnits": { + "type": ["null", "number"] + }, + "p80ForecastUnits": { + "type": ["null", "number"] + }, + "p90ForecastUnits": { + "type": ["null", "number"] + }, + "dataEndTime": { + "type": ["null", "string"], + "format": "date" + } } }, "supported_sync_modes": ["full_refresh"] diff --git a/airbyte-integrations/connectors/source-amazon-seller-partner/erd/estimated_relationships.json b/airbyte-integrations/connectors/source-amazon-seller-partner/erd/estimated_relationships.json index a1eb140e1aef..0967ef424bce 100644 --- a/airbyte-integrations/connectors/source-amazon-seller-partner/erd/estimated_relationships.json +++ b/airbyte-integrations/connectors/source-amazon-seller-partner/erd/estimated_relationships.json @@ -1,247 +1 @@ -{ - "streams": [ - { - "name": "FBA_CUSTOMER_RETURNS", - "relations": { - "order-id": "Order_DATE_GENERAL.amazon-order-id" - } - }, - { - "name": "GET_AFN_INVENTORY_DATA", - "relations": {} - }, - { - "name": "GET_AFN_INVENTORY_DATA_BY_COUNTRY", - "relations": {} - }, - { - "name": "Order detail", - "relations": { - "order-id": "Order_DATE_GENERAL.amazon-order-id" - } - }, - { - "name": "GET_FBA_FULFILLMENT_REMOVAL_SHIPMENT_DETAIL_DATA", - "relations": { - "order-id": "Order_DATE_GENERAL.amazon-order-id" - } - }, - { - "name": "FBA_REPLACEMENT", - "relations": { - "original-amazon-order-id": "Order_DATE_GENERAL.amazon-order-id" - } - }, - { - "name": "FEE_CHARGES", - "relations": {} - }, - { - "name": "Fee_charges", - "relations": {} - }, - { - "name": "GET_RESTOCK_INVENTORY_RECOMMENDATIONS_REPORT", - "relations": {} - }, - { - "name": "GET_FLAT_FILE_ACTIONABLE_ORDER_DATA_SHIPPING", - "relations": { - "order-id": "Order_DATE_GENERAL.amazon-order-id" - } - }, - { - "name": "GET_FLAT_FILE_OPEN_LISTINGS_DATA", - "relations": {} - }, - { - "name": "Order_DATE_GENERAL", - "relations": {} - }, - { - "name": "GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL", - "relations": {} - }, - { - "name": "GET_V2_SETTLEMENT_REPORT_DATA_FLAT_FILE", - "relations": { - "order-id": "Order_DATE_GENERAL.amazon-order-id", - "merchant-order-id": "Order_DATE_GENERAL.merchant-order-id" - } - }, - { - "name": "GET_AMAZON_FULFILLED_SHIPMENTS_DATA_GENERAL", - "relations": { - "amazon-order-id": "Order_DATE_GENERAL.amazon-order-id", - "merchant-order-id": "Order_DATE_GENERAL.merchant-order-id", - "shipment-id": "VendorOrders.purchaseOrderNumber" - } - }, - { - "name": "GET_MERCHANT_LISTINGS_ALL_DATA", - "relations": {} - }, - { - "name": "VendorDirectFulfillmentShipping", - "relations": {} - }, - { - "name": "Orders", - "relations": {} - }, - { - "name": "OrderItems", - "relations": { - "AmazonOrderId": "Orders.AmazonOrderId" - } - }, - { - "name": "GET_ORDER_REPORT_DATA_SHIPPING", - "relations": {} - }, - { - "name": "GET_SELLER_FEEDBACK_DATA", - "relations": { - "order_id": "Order_DATE_GENERAL.amazon-order-id" - } - }, - { - "name": "GET_XML_BROWSE_TREE_DATA", - "relations": {} - }, - { - "name": "ListFinancialEventGroups", - "relations": {} - }, - { - "name": "ListFinancialEvents", - "relations": {} - }, - { - "name": "GET_LEDGER_DETAIL_VIEW_DATA", - "relations": {} - }, - { - "name": "FBA FEES", - "relations": {} - }, - { - "name": "GET_FBA_FULFILLMENT_CUSTOMER_SHIPMENT_PROMOTION_DATA", - "relations": { - "amazon-order-id": "Order_DATE_GENERAL.amazon-order-id" - } - }, - { - "name": "GET_FBA_MYI_UNSUPPRESSED_INVENTORY_DATA", - "relations": {} - }, - { - "name": "GET_MERCHANT_CANCELLED_LISTINGS_DATA", - "relations": {} - }, - { - "name": "GET_MERCHANT_LISTINGS_DATA", - "relations": {} - }, - { - "name": "GET_MERCHANT_LISTINGS_DATA_BACK_COMPAT", - "relations": {} - }, - { - "name": "GET_MERCHANT_LISTINGS_INACTIVE_DATA", - "relations": {} - }, - { - "name": "GET_STRANDED_INVENTORY_UI_DATA", - "relations": {} - }, - { - "name": "GET_XML_ALL_ORDERS_DATA_BY_ORDER_DATE_GENERAL", - "relations": {} - }, - { - "name": "GET_MERCHANTS_LISTINGS_FYP_REPORT", - "relations": {} - }, - { - "name": "GET_FBA_SNS_FORECAST_DATA", - "relations": {} - }, - { - "name": "Performance_Data", - "relations": {} - }, - { - "name": "GET_FLAT_FILE_ARCHIVED_ORDERS_DATA_BY_ORDER_DATE", - "relations": {} - }, - { - "name": "GET_FLAT_FILE_RETURNS_DATA_BY_RETURN_DATE", - "relations": { - "Order ID": "Order_DATE_GENERAL.amazon-order-id" - } - }, - { - "name": "GET_FBA_INVENTORY_PLANNING_DATA", - "relations": {} - }, - { - "name": "GET_LEDGER_SUMMARY_VIEW_DATA", - "relations": {} - }, - { - "name": "FBA_REIMBURSEMENTS", - "relations": { - "amazon-order-id": "Order_DATE_GENERAL.amazon-order-id" - } - }, - { - "name": "VendorOrders", - "relations": {} - }, - { - "name": "GET_VENDOR_FORECASTING_FRESH_REPORT", - "relations": {} - }, - { - "name": "GET_VENDOR_FORECASTING_RETAIL_REPORT", - "relations": {} - }, - { - "name": "GET_BRAND_ANALYTICS_MARKET_BASKET_REPORT", - "relations": {} - }, - { - "name": "GET_BRAND_ANALYTICS_SEARCH_TERMS_REPORT", - "relations": {} - }, - { - "name": "GET_BRAND_ANALYTICS_REPEAT_PURCHASE_REPORT", - "relations": {} - }, - { - "name": "GET_SALES_AND_TRAFFIC_REPORT", - "relations": {} - }, - { - "name": "GET_VENDOR_SALES_REPORT", - "relations": {} - }, - { - "name": "GET_VENDOR_INVENTORY_REPORT", - "relations": {} - }, - { - "name": "GET_VENDOR_NET_PURE_PRODUCT_MARGIN_REPORT", - "relations": {} - }, - { - "name": "GET_VENDOR_REAL_TIME_INVENTORY_REPORT", - "relations": {} - }, - { - "name": "GET_VENDOR_TRAFFIC_REPORT", - "relations": {} - } - ] -} +{} diff --git a/airbyte-integrations/connectors/source-amazon-seller-partner/erd/source.dbml b/airbyte-integrations/connectors/source-amazon-seller-partner/erd/source.dbml index abcc21360b90..9988b2d0f64a 100644 --- a/airbyte-integrations/connectors/source-amazon-seller-partner/erd/source.dbml +++ b/airbyte-integrations/connectors/source-amazon-seller-partner/erd/source.dbml @@ -741,28 +741,6 @@ Table "GET_MERCHANTS_LISTINGS_FYP_REPORT" { "dataEndTime" string } -Table "GET_FBA_SNS_FORECAST_DATA" { - "offer-state" string - "snapshot-date" string - "sku" string - "fnsku" string - "asin" string - "estimated-avg-sns-discount-next-8-weeks" string - "product-name" string - "country" string - "active-subscriptions" string - "week-1-start-date" string - "scheduled-sns-units-week-1" string - "scheduled-sns-units-week-2" string - "scheduled-sns-units-week-3" string - "scheduled-sns-units-week-4" string - "scheduled-sns-units-week-5" string - "scheduled-sns-units-week-6" string - "scheduled-sns-units-week-7" string - "scheduled-sns-units-week-8" string - "dataEndTime" string -} - Table "GET_FLAT_FILE_ARCHIVED_ORDERS_DATA_BY_ORDER_DATE" { "amazon-order-id" string "merchant-order-id" string @@ -1082,4 +1060,4 @@ Ref { Ref { "OrderItems"."AmazonOrderId" <> "Orders"."AmazonOrderId" -} \ No newline at end of file +} diff --git a/airbyte-integrations/connectors/source-amazon-seller-partner/integration_tests/configured_catalog_get_fba_sns_forecast_data.json b/airbyte-integrations/connectors/source-amazon-seller-partner/integration_tests/configured_catalog_get_fba_sns_forecast_data.json deleted file mode 100644 index 4a447e44ae41..000000000000 --- a/airbyte-integrations/connectors/source-amazon-seller-partner/integration_tests/configured_catalog_get_fba_sns_forecast_data.json +++ /dev/null @@ -1,40 +0,0 @@ -{ - "streams": [ - { - "stream": { - "name": "GET_FBA_SNS_FORECAST_DATA", - "json_schema": { - "title": "Subscribe and Save Forecast Report", - "description": "", - "type": "object", - "$schema": "http://json-schema.org/draft-07/schema#", - "properties": { - "offer-state": { "type": ["null", "string"] }, - "snapshot-date": { "type": ["null", "string"] }, - "sku": { "type": ["null", "string"] }, - "fnsku": { "type": ["null", "string"] }, - "asin": { "type": ["null", "string"] }, - "estimated-avg-sns-discount-next-8-weeks": { - "type": ["null", "string"] - }, - "product-name": { "type": ["null", "string"] }, - "country": { "type": ["null", "string"] }, - "active-subscriptions": { "type": ["null", "string"] }, - "week-1-start-date": { "type": ["null", "string"] }, - "scheduled-sns-units-week-1": { "type": ["null", "string"] }, - "scheduled-sns-units-week-2": { "type": ["null", "string"] }, - "scheduled-sns-units-week-3": { "type": ["null", "string"] }, - "scheduled-sns-units-week-4": { "type": ["null", "string"] }, - "scheduled-sns-units-week-5": { "type": ["null", "string"] }, - "scheduled-sns-units-week-6": { "type": ["null", "string"] }, - "scheduled-sns-units-week-7": { "type": ["null", "string"] }, - "scheduled-sns-units-week-8": { "type": ["null", "string"] } - } - }, - "supported_sync_modes": ["full_refresh"] - }, - "sync_mode": "full_refresh", - "destination_sync_mode": "overwrite" - } - ] -} diff --git a/airbyte-integrations/connectors/source-amazon-seller-partner/integration_tests/configured_catalog_get_fba_sns_performance_data.json b/airbyte-integrations/connectors/source-amazon-seller-partner/integration_tests/configured_catalog_get_fba_sns_performance_data.json deleted file mode 100644 index 42072661c95a..000000000000 --- a/airbyte-integrations/connectors/source-amazon-seller-partner/integration_tests/configured_catalog_get_fba_sns_performance_data.json +++ /dev/null @@ -1,44 +0,0 @@ -{ - "streams": [ - { - "stream": { - "name": "GET_FBA_SNS_PERFORMANCE_DATA", - "json_schema": { - "title": "Subscribe and Save Performance Report", - "description": "", - "type": "object", - "$schema": "http://json-schema.org/draft-07/schema#", - "properties": { - "offer-state": { "type": ["null", "string"] }, - "snapshot-date": { "type": ["null", "string"] }, - "sku": { "type": ["null", "string"] }, - "fnsku": { "type": ["null", "string"] }, - "asin": { "type": ["null", "string"] }, - "product-name": { "type": ["null", "string"] }, - "country": { "type": ["null", "string"] }, - "week-1-start-date": { "type": ["null", "string"] }, - "sns-units-shipped-week-1": { "type": ["null", "string"] }, - "oos-rate-week-1": { "type": ["null", "string"] }, - "sns-sale-price-week-1": { "type": ["null", "string"] }, - "sns-discount-week-1": { "type": ["null", "string"] }, - "sns-units-shipped-week-2": { "type": ["null", "string"] }, - "oos-rate-week-2": { "type": ["null", "string"] }, - "sns-sale-price-week-2": { "type": ["null", "string"] }, - "sns-discount-week-2": { "type": ["null", "string"] }, - "sns-units-shipped-week-3": { "type": ["null", "string"] }, - "oos-rate-week-3": { "type": ["null", "string"] }, - "sns-sale-price-week-3": { "type": ["null", "string"] }, - "sns-discount-week-3": { "type": ["null", "string"] }, - "sns-units-shipped-week-4": { "type": ["null", "string"] }, - "oos-rate-week-4": { "type": ["null", "string"] }, - "sns-sale-price-week-4": { "type": ["null", "string"] }, - "sns-discount-week-4": { "type": ["null", "string"] } - } - }, - "supported_sync_modes": ["full_refresh"] - }, - "sync_mode": "full_refresh", - "destination_sync_mode": "overwrite" - } - ] -} diff --git a/airbyte-integrations/connectors/source-amazon-seller-partner/integration_tests/future_state.json b/airbyte-integrations/connectors/source-amazon-seller-partner/integration_tests/future_state.json index 2d1c79833fcf..7b7ab6de2341 100644 --- a/airbyte-integrations/connectors/source-amazon-seller-partner/integration_tests/future_state.json +++ b/airbyte-integrations/connectors/source-amazon-seller-partner/integration_tests/future_state.json @@ -164,28 +164,6 @@ } } }, - { - "type": "STREAM", - "stream": { - "stream_state": { - "dataEndTime": "2121-07-01T00:00:00Z" - }, - "stream_descriptor": { - "name": "GET_FBA_SNS_FORECAST_DATA" - } - } - }, - { - "type": "STREAM", - "stream": { - "stream_state": { - "dataEndTime": "2121-07-01T00:00:00Z" - }, - "stream_descriptor": { - "name": "GET_FBA_SNS_PERFORMANCE_DATA" - } - } - }, { "type": "STREAM", "stream": { diff --git a/airbyte-integrations/connectors/source-amazon-seller-partner/integration_tests/sample_state.json b/airbyte-integrations/connectors/source-amazon-seller-partner/integration_tests/sample_state.json index 312e50d5d91f..540f4368d8d5 100644 --- a/airbyte-integrations/connectors/source-amazon-seller-partner/integration_tests/sample_state.json +++ b/airbyte-integrations/connectors/source-amazon-seller-partner/integration_tests/sample_state.json @@ -164,28 +164,6 @@ } } }, - { - "type": "STREAM", - "stream": { - "stream_descriptor": { - "name": "GET_FBA_SNS_FORECAST_DATA" - }, - "stream_state": { - "LastUpdateDate": "2021-07-01T00:00:00Z" - } - } - }, - { - "type": "STREAM", - "stream": { - "stream_descriptor": { - "name": "GET_FBA_SNS_PERFORMANCE_DATA" - }, - "stream_state": { - "LastUpdateDate": "2021-07-01T00:00:00Z" - } - } - }, { "type": "STREAM", "stream": { diff --git a/airbyte-integrations/connectors/source-amazon-seller-partner/manifest.yaml b/airbyte-integrations/connectors/source-amazon-seller-partner/manifest.yaml index 6b18115285a4..498eba0adbb5 100644 --- a/airbyte-integrations/connectors/source-amazon-seller-partner/manifest.yaml +++ b/airbyte-integrations/connectors/source-amazon-seller-partner/manifest.yaml @@ -164,8 +164,6 @@ spec: - GET_FBA_INVENTORY_PLANNING_DATA - GET_FBA_MYI_UNSUPPRESSED_INVENTORY_DATA - GET_FBA_REIMBURSEMENTS_DATA - - GET_FBA_SNS_FORECAST_DATA - - GET_FBA_SNS_PERFORMANCE_DATA - GET_FBA_STORAGE_FEE_CHARGES_DATA - GET_FLAT_FILE_ACTIONABLE_ORDER_DATA_SHIPPING - GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL @@ -1772,90 +1770,6 @@ definitions: schema: $ref: "#/schemas/get_flat_file_archived_orders_data_by_order_date" - get_fba_sns_performance_data: - type: DeclarativeStream - name: GET_FBA_SNS_PERFORMANCE_DATA - primary_key: [] - incremental_sync: - type: DatetimeBasedCursor - cursor_field: dataEndTime - cursor_datetime_formats: - - "%Y-%m-%d" - - "%Y-%m-%dT%H:%M:%SZ" - datetime_format: "%Y-%m-%dT%H:%M:%SZ" - # The default max step value for streams in Amazon Seller Partner is 365 days. It can optionally be configured lower based on customer configs - step: "P{{ min( config.get('period_in_days', 365), 365 ) }}D" - cursor_granularity: "PT1S" - start_datetime: - type: MinMaxDatetime - datetime: "{{ format_datetime( max(config.get('replication_start_date', (now_utc() - duration('P730D')).strftime('%Y-%m-%dT%H:%M:%SZ') ), (now_utc() - duration('P730D')).strftime('%Y-%m-%dT%H:%M:%SZ')), '%Y-%m-%dT%H:%M:%SZ') }}" - datetime_format: "%Y-%m-%dT%H:%M:%SZ" - end_datetime: - type: MinMaxDatetime - datetime: "{{ format_datetime(config['replication_end_date'] if config.get('replication_end_date') else now_utc(), '%Y-%m-%dT%H:%M:%SZ') }}" - datetime_format: "%Y-%m-%dT%H:%M:%SZ" - retriever: - $ref: "#/definitions/basic_async_retriever" - creation_requester: - $ref: "#/definitions/basic_async_retriever/creation_requester" - request_body_json: - reportType: GET_FBA_SNS_PERFORMANCE_DATA - marketplaceIds: '{{ [config["marketplace_id"]] }}' - dataStartTime: "{{ stream_slice.cursor_slice.start_time }}" - dataEndTime: "{{ stream_slice.cursor_slice.end_time }}" - # Records in this stream do not contain a cursor timestamp, so we inject the upper boundary of the slice requested which serves as the checkpoint - transformations: - - type: AddFields - fields: - - path: ["dataEndTime"] - value: "{{ format_datetime(stream_slice['end_time'], '%Y-%m-%d') }}" - schema_loader: - type: InlineSchemaLoader - schema: - $ref: "#/schemas/get_fba_sns_performance_data" - - get_fba_sns_forecast_data: - type: DeclarativeStream - name: GET_FBA_SNS_FORECAST_DATA - primary_key: [] - incremental_sync: - type: DatetimeBasedCursor - cursor_field: dataEndTime - cursor_datetime_formats: - - "%Y-%m-%d" - - "%Y-%m-%dT%H:%M:%SZ" - datetime_format: "%Y-%m-%dT%H:%M:%SZ" - # The default max step value for streams in Amazon Seller Partner is 365 days. It can optionally be configured lower based on customer configs - step: "P{{ min( config.get('period_in_days', 365), 365 ) }}D" - cursor_granularity: "PT1S" - start_datetime: - type: MinMaxDatetime - datetime: "{{ format_datetime( max(config.get('replication_start_date', (now_utc() - duration('P730D')).strftime('%Y-%m-%dT%H:%M:%SZ') ), (now_utc() - duration('P730D')).strftime('%Y-%m-%dT%H:%M:%SZ')), '%Y-%m-%dT%H:%M:%SZ') }}" - datetime_format: "%Y-%m-%dT%H:%M:%SZ" - end_datetime: - type: MinMaxDatetime - datetime: "{{ format_datetime(config['replication_end_date'] if config.get('replication_end_date') else now_utc(), '%Y-%m-%dT%H:%M:%SZ') }}" - datetime_format: "%Y-%m-%dT%H:%M:%SZ" - retriever: - $ref: "#/definitions/basic_async_retriever" - creation_requester: - $ref: "#/definitions/basic_async_retriever/creation_requester" - request_body_json: - reportType: GET_FBA_SNS_FORECAST_DATA - marketplaceIds: '{{ [config["marketplace_id"]] }}' - dataStartTime: "{{ stream_slice.cursor_slice.start_time }}" - dataEndTime: "{{ stream_slice.cursor_slice.end_time }}" - # Records in this stream do not contain a cursor timestamp, so we inject the upper boundary of the slice requested which serves as the checkpoint - transformations: - - type: AddFields - fields: - - path: ["dataEndTime"] - value: "{{ format_datetime(stream_slice['end_time'], '%Y-%m-%d') }}" - schema_loader: - type: InlineSchemaLoader - schema: - $ref: "#/schemas/get_fba_sns_forecast_data" - get_merchants_listings_fyp_report: type: DeclarativeStream name: GET_MERCHANTS_LISTINGS_FYP_REPORT @@ -2860,8 +2774,6 @@ streams: - $ref: "#/definitions/streams/get_fba_inventory_planning_data" - $ref: "#/definitions/streams/get_flat_file_returns_data_by_return_date" - $ref: "#/definitions/streams/get_flat_file_archived_orders_data_by_order_date" - - $ref: "#/definitions/streams/get_fba_sns_performance_data" - - $ref: "#/definitions/streams/get_fba_sns_forecast_data" - $ref: "#/definitions/streams/get_merchants_listings_fyp_report" - $ref: "#/definitions/streams/get_merchant_cancelled_listings_data" - $ref: "#/definitions/streams/get_merchant_listings_data_back_compat" @@ -5561,245 +5473,6 @@ schemas: - 'null' - string format: date - get_fba_sns_performance_data: - title: Subscribe and Save Performance Report - description: '' - type: object - $schema: http://json-schema.org/draft-07/schema# - properties: - offer-state: - description: Current state of the offer for the product. - type: - - 'null' - - string - snapshot-date: - description: Date and time when the snapshot of data is taken. - type: - - 'null' - - string - format: date-time - sku: - description: Stock Keeping Unit for the product. - type: - - 'null' - - string - fnsku: - description: Fulfillment Network SKU. - type: - - 'null' - - string - asin: - description: Unique identifier for the product ASIN. - type: - - 'null' - - string - product-name: - description: Name of the product. - type: - - 'null' - - string - country: - description: Country where the data is collected. - type: - - 'null' - - string - week-1-start-date: - description: Start date of week 1 in date-time format. - type: - - 'null' - - string - format: date-time - sns-units-shipped-week-1: - description: Units shipped on SNS for week 1. - type: - - 'null' - - string - oos-rate-week-1: - description: Out of stock rate for week 1. - type: - - 'null' - - string - sns-sale-price-week-1: - description: Sale price on SNS for week 1. - type: - - 'null' - - string - sns-discount-week-1: - description: Discount applied in week 1 on SNS. - type: - - 'null' - - string - sns-units-shipped-week-2: - description: Units shipped on SNS for week 2. - type: - - 'null' - - string - oos-rate-week-2: - description: Out of stock rate for week 2. - type: - - 'null' - - string - sns-sale-price-week-2: - description: Sale price on SNS for week 2. - type: - - 'null' - - string - sns-discount-week-2: - description: Discount applied in week 2 on SNS. - type: - - 'null' - - string - sns-units-shipped-week-3: - description: Units shipped on SNS for week 3. - type: - - 'null' - - string - oos-rate-week-3: - description: Out of stock rate for week 3. - type: - - 'null' - - string - sns-sale-price-week-3: - description: Sale price on SNS for week 3. - type: - - 'null' - - string - sns-discount-week-3: - description: Discount applied in week 3 on SNS. - type: - - 'null' - - string - sns-units-shipped-week-4: - description: Units shipped on SNS for week 4. - type: - - 'null' - - string - oos-rate-week-4: - description: Out of stock rate for week 4. - type: - - 'null' - - string - sns-sale-price-week-4: - description: Sale price on SNS for week 4. - type: - - 'null' - - string - sns-discount-week-4: - description: Discount applied in week 4 on SNS. - type: - - 'null' - - string - dataEndTime: - description: End time of the data in date format. - type: - - 'null' - - string - format: date - get_fba_sns_forecast_data: - title: Subscribe and Save Forecast Report - description: '' - type: object - $schema: http://json-schema.org/draft-07/schema# - properties: - offer-state: - description: Current state of the offer for the product. - type: - - 'null' - - string - snapshot-date: - description: Date and time when the snapshot of the data was taken. - type: - - 'null' - - string - format: date-time - sku: - description: Stock Keeping Unit (SKU) for the product. - type: - - 'null' - - string - fnsku: - description: Fulfillment Network SKU (FNSKU) for the product. - type: - - 'null' - - string - asin: - description: Unique identifier for the ASIN (Amazon Standard Identification Number). - type: - - 'null' - - string - estimated-avg-sns-discount-next-8-weeks: - description: Estimated average discount on Subscribe & Save units for the next - 8 weeks. - type: - - 'null' - - string - product-name: - description: Name of the product associated with the ASIN. - type: - - 'null' - - string - country: - description: Country for which the forecast data is applicable. - type: - - 'null' - - string - active-subscriptions: - description: Number of active subscriptions for the ASIN in the specified country. - type: - - 'null' - - string - week-1-start-date: - description: Start date and time for week 1 of the forecast period. - type: - - 'null' - - string - format: date-time - scheduled-sns-units-week-1: - description: Number of scheduled Subscribe & Save units for week 1. - type: - - 'null' - - string - scheduled-sns-units-week-2: - description: Number of scheduled Subscribe & Save units for week 2. - type: - - 'null' - - string - scheduled-sns-units-week-3: - description: Number of scheduled Subscribe & Save units for week 3. - type: - - 'null' - - string - scheduled-sns-units-week-4: - description: Number of scheduled Subscribe & Save units for week 4. - type: - - 'null' - - string - scheduled-sns-units-week-5: - description: Number of scheduled Subscribe & Save units for week 5. - type: - - 'null' - - string - scheduled-sns-units-week-6: - description: Number of scheduled Subscribe & Save units for week 6. - type: - - 'null' - - string - scheduled-sns-units-week-7: - description: Number of scheduled Subscribe & Save units for week 7. - type: - - 'null' - - string - scheduled-sns-units-week-8: - description: Number of scheduled Subscribe & Save units for week 8. - type: - - 'null' - - string - dataEndTime: - description: End time for the forecast data, indicated in date format. - type: - - 'null' - - string - format: date get_merchants_listings_fyp_report: title: Suppressed Listings Report description: '' diff --git a/airbyte-integrations/connectors/source-amazon-seller-partner/metadata.yaml b/airbyte-integrations/connectors/source-amazon-seller-partner/metadata.yaml index f6b1c23487d6..4d81c1f535c9 100644 --- a/airbyte-integrations/connectors/source-amazon-seller-partner/metadata.yaml +++ b/airbyte-integrations/connectors/source-amazon-seller-partner/metadata.yaml @@ -53,6 +53,9 @@ data: 4.0.0: message: Stream `GET_FBA_STORAGE_FEE_CHARGES_DATA` schema has been updated to match Amazon Seller Partner. Users will need to refresh the source schema and reset this stream after upgrading. upgradeDeadline: "2024-03-11" + 5.0.0: + message: "Deprecated FBA Subscribe and Save report types (GET_FBA_SNS_FORECAST_DATA and GET_FBA_SNS_PERFORMANCE_DATA) have been removed per Amazon SP-API deprecation. See: https://developer-docs.amazon.com/sp-api/changelog/deprecation-of-two-fba-subscribe-and-save-report-types" + upgradeDeadline: "2025-12-11" supportLevel: certified tags: - language:manifest-only diff --git a/airbyte-integrations/connectors/source-amazon-seller-partner/unit_tests/integration/test_report_based_streams.py b/airbyte-integrations/connectors/source-amazon-seller-partner/unit_tests/integration/test_report_based_streams.py index 1645186c40bd..78fe57268e81 100644 --- a/airbyte-integrations/connectors/source-amazon-seller-partner/unit_tests/integration/test_report_based_streams.py +++ b/airbyte-integrations/connectors/source-amazon-seller-partner/unit_tests/integration/test_report_based_streams.py @@ -42,13 +42,11 @@ ("GET_AFN_INVENTORY_DATA_BY_COUNTRY", "csv"), ("GET_FLAT_FILE_RETURNS_DATA_BY_RETURN_DATE", "csv"), ("GET_FBA_FULFILLMENT_CUSTOMER_RETURNS_DATA", "csv"), - ("GET_FBA_SNS_FORECAST_DATA", "csv"), ("GET_AFN_INVENTORY_DATA", "csv"), ("GET_MERCHANT_CANCELLED_LISTINGS_DATA", "csv"), ("GET_FBA_FULFILLMENT_CUSTOMER_SHIPMENT_PROMOTION_DATA", "csv"), ("GET_LEDGER_SUMMARY_VIEW_DATA", "csv"), ("GET_FLAT_FILE_ARCHIVED_ORDERS_DATA_BY_ORDER_DATE", "csv"), - ("GET_FBA_SNS_PERFORMANCE_DATA", "csv"), ("GET_FBA_ESTIMATED_FBA_FEES_TXT_DATA", "csv"), ("GET_FBA_INVENTORY_PLANNING_DATA", "csv"), ("GET_FBA_STORAGE_FEE_CHARGES_DATA", "csv"), diff --git a/airbyte-integrations/connectors/source-amazon-seller-partner/unit_tests/test_source.py b/airbyte-integrations/connectors/source-amazon-seller-partner/unit_tests/test_source.py index 97baaa01fd54..725710849cf1 100644 --- a/airbyte-integrations/connectors/source-amazon-seller-partner/unit_tests/test_source.py +++ b/airbyte-integrations/connectors/source-amazon-seller-partner/unit_tests/test_source.py @@ -141,7 +141,7 @@ def test_streams(connector_config_without_start_date): def test_streams_count(connector_config_without_start_date, monkeypatch): streams = get_source(connector_config_without_start_date).streams(connector_config_without_start_date) - assert len(streams) == 45 + assert len(streams) == 43 # TODO: Renable this test once this type of validation is supported