Skip to content

Commit e6e0b49

Browse files
Anton Karpetsjatinyadav-cc
Anton Karpets
authored and
jatinyadav-cc
committed
✨Source Amazon Seller Partner: add VendorOrders stream (airbytehq#35273)
1 parent a2e782d commit e6e0b49

File tree

14 files changed

+1058
-193
lines changed

14 files changed

+1058
-193
lines changed

‎airbyte-integrations/connectors/source-amazon-seller-partner/acceptance-test-config.yml

+2
Original file line numberDiff line numberDiff line change
@@ -130,6 +130,8 @@ acceptance_tests:
130130
bypass_reason: "Data cannot be seeded in the test account, integration tests added for the stream instead"
131131
- name: GET_VENDOR_TRAFFIC_REPORT
132132
bypass_reason: "Data cannot be seeded in the test account, integration tests added for the stream instead"
133+
- name: VendorOrders
134+
bypass_reason: "Data cannot be seeded in the test account, integration tests added for the stream instead"
133135
incremental:
134136
tests:
135137
- config_path: "secrets/config.json"

‎airbyte-integrations/connectors/source-amazon-seller-partner/metadata.yaml

+1-1
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ data:
1515
connectorSubtype: api
1616
connectorType: source
1717
definitionId: e55879a8-0ef8-4557-abcf-ab34c53ec460
18-
dockerImageTag: 3.3.2
18+
dockerImageTag: 3.4.0
1919
dockerRepository: airbyte/source-amazon-seller-partner
2020
documentationUrl: https://docs.airbyte.com/integrations/sources/amazon-seller-partner
2121
githubIssueLabel: source-amazon-seller-partner

‎airbyte-integrations/connectors/source-amazon-seller-partner/source_amazon_seller_partner/schemas/VendorOrders.json

+354
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,354 @@
1+
{
2+
"title": "Vendor Orders",
3+
"description": "All vendor purchase orders that were updated after a specified date",
4+
"type": "object",
5+
"$schema": "http://json-schema.org/draft-07/schema#",
6+
"properties": {
7+
"purchaseOrderNumber": {
8+
"type": ["null", "string"]
9+
},
10+
"purchaseOrderState": {
11+
"type": ["null", "string"]
12+
},
13+
"orderDetails": {
14+
"type": ["null", "object"],
15+
"properties": {
16+
"purchaseOrderDate": {
17+
"type": ["null", "string"],
18+
"format": "date-time"
19+
},
20+
"purchaseOrderChangedDate": {
21+
"type": ["null", "string"],
22+
"format": "date-time"
23+
},
24+
"purchaseOrderStateChangedDate": {
25+
"type": ["null", "string"],
26+
"format": "date-time"
27+
},
28+
"purchaseOrderType": {
29+
"type": ["null", "string"]
30+
},
31+
"importDetails": {
32+
"type": ["null", "object"],
33+
"properties": {
34+
"methodOfPayment": {
35+
"type": ["null", "string"]
36+
},
37+
"internationalCommercialTerms": {
38+
"type": ["null", "string"]
39+
},
40+
"portOfDelivery": {
41+
"type": ["null", "string"]
42+
},
43+
"importContainers": {
44+
"type": ["null", "string"]
45+
},
46+
"shippingInstructions": {
47+
"type": ["null", "string"]
48+
}
49+
}
50+
},
51+
"dealCode": {
52+
"type": ["null", "string"]
53+
},
54+
"paymentMethod": {
55+
"type": ["null", "string"]
56+
},
57+
"buyingParty": {
58+
"type": ["null", "object"],
59+
"properties": {
60+
"partyId": {
61+
"type": ["null", "string"]
62+
},
63+
"address": {
64+
"type": ["null", "object"],
65+
"properties": {
66+
"name": {
67+
"type": ["null", "string"]
68+
},
69+
"addressLine1": {
70+
"type": ["null", "string"]
71+
},
72+
"addressLine2": {
73+
"type": ["null", "string"]
74+
},
75+
"addressLine3": {
76+
"type": ["null", "string"]
77+
},
78+
"city": {
79+
"type": ["null", "string"]
80+
},
81+
"county": {
82+
"type": ["null", "string"]
83+
},
84+
"district": {
85+
"type": ["null", "string"]
86+
},
87+
"stateOrRegion": {
88+
"type": ["null", "string"]
89+
},
90+
"postalCode": {
91+
"type": ["null", "string"]
92+
},
93+
"countryCode": {
94+
"type": ["null", "string"]
95+
},
96+
"phone": {
97+
"type": ["null", "string"]
98+
}
99+
}
100+
},
101+
"taxInfo": {
102+
"type": ["null", "object"],
103+
"properties": {
104+
"taxType": {
105+
"type": ["null", "string"]
106+
},
107+
"taxRegistrationNumber": {
108+
"type": ["null", "string"]
109+
}
110+
}
111+
}
112+
}
113+
},
114+
"sellingParty": {
115+
"type": ["null", "object"],
116+
"properties": {
117+
"partyId": {
118+
"type": ["null", "string"]
119+
},
120+
"address": {
121+
"type": ["null", "object"],
122+
"properties": {
123+
"name": {
124+
"type": ["null", "string"]
125+
},
126+
"addressLine1": {
127+
"type": ["null", "string"]
128+
},
129+
"addressLine2": {
130+
"type": ["null", "string"]
131+
},
132+
"addressLine3": {
133+
"type": ["null", "string"]
134+
},
135+
"city": {
136+
"type": ["null", "string"]
137+
},
138+
"county": {
139+
"type": ["null", "string"]
140+
},
141+
"district": {
142+
"type": ["null", "string"]
143+
},
144+
"stateOrRegion": {
145+
"type": ["null", "string"]
146+
},
147+
"postalCode": {
148+
"type": ["null", "string"]
149+
},
150+
"countryCode": {
151+
"type": ["null", "string"]
152+
},
153+
"phone": {
154+
"type": ["null", "string"]
155+
}
156+
}
157+
},
158+
"taxInfo": {
159+
"type": ["null", "object"],
160+
"properties": {
161+
"taxType": {
162+
"type": ["null", "string"]
163+
},
164+
"taxRegistrationNumber": {
165+
"type": ["null", "string"]
166+
}
167+
}
168+
}
169+
}
170+
},
171+
"shipToParty": {
172+
"type": ["null", "object"],
173+
"properties": {
174+
"partyId": {
175+
"type": ["null", "string"]
176+
},
177+
"address": {
178+
"type": ["null", "object"],
179+
"properties": {
180+
"name": {
181+
"type": ["null", "string"]
182+
},
183+
"addressLine1": {
184+
"type": ["null", "string"]
185+
},
186+
"addressLine2": {
187+
"type": ["null", "string"]
188+
},
189+
"addressLine3": {
190+
"type": ["null", "string"]
191+
},
192+
"city": {
193+
"type": ["null", "string"]
194+
},
195+
"county": {
196+
"type": ["null", "string"]
197+
},
198+
"district": {
199+
"type": ["null", "string"]
200+
},
201+
"stateOrRegion": {
202+
"type": ["null", "string"]
203+
},
204+
"postalCode": {
205+
"type": ["null", "string"]
206+
},
207+
"countryCode": {
208+
"type": ["null", "string"]
209+
},
210+
"phone": {
211+
"type": ["null", "string"]
212+
}
213+
}
214+
},
215+
"taxInfo": {
216+
"type": ["null", "object"],
217+
"properties": {
218+
"taxType": {
219+
"type": ["null", "string"]
220+
},
221+
"taxRegistrationNumber": {
222+
"type": ["null", "string"]
223+
}
224+
}
225+
}
226+
}
227+
},
228+
"billToParty": {
229+
"type": ["null", "object"],
230+
"properties": {
231+
"partyId": {
232+
"type": ["null", "string"]
233+
},
234+
"address": {
235+
"type": ["null", "object"],
236+
"properties": {
237+
"name": {
238+
"type": ["null", "string"]
239+
},
240+
"addressLine1": {
241+
"type": ["null", "string"]
242+
},
243+
"addressLine2": {
244+
"type": ["null", "string"]
245+
},
246+
"addressLine3": {
247+
"type": ["null", "string"]
248+
},
249+
"city": {
250+
"type": ["null", "string"]
251+
},
252+
"county": {
253+
"type": ["null", "string"]
254+
},
255+
"district": {
256+
"type": ["null", "string"]
257+
},
258+
"stateOrRegion": {
259+
"type": ["null", "string"]
260+
},
261+
"postalCode": {
262+
"type": ["null", "string"]
263+
},
264+
"countryCode": {
265+
"type": ["null", "string"]
266+
},
267+
"phone": {
268+
"type": ["null", "string"]
269+
}
270+
}
271+
},
272+
"taxInfo": {
273+
"type": ["null", "object"],
274+
"properties": {
275+
"taxType": {
276+
"type": ["null", "string"]
277+
},
278+
"taxRegistrationNumber": {
279+
"type": ["null", "string"]
280+
}
281+
}
282+
}
283+
}
284+
},
285+
"shipWindow": {
286+
"type": ["null", "string"]
287+
},
288+
"deliveryWindow": {
289+
"type": ["null", "string"]
290+
},
291+
"items": {
292+
"type": ["null", "array"],
293+
"items": {
294+
"type": ["null", "object"],
295+
"properties": {
296+
"itemSequenceNumber": {
297+
"type": ["null", "string"]
298+
},
299+
"amazonProductIdentifier": {
300+
"type": ["null", "string"]
301+
},
302+
"vendorProductIdentifier": {
303+
"type": ["null", "string"]
304+
},
305+
"orderedQuantity": {
306+
"type": ["null", "object"],
307+
"properties": {
308+
"amount": {
309+
"type": ["null", "integer"]
310+
},
311+
"unitOfMeasure": {
312+
"type": ["null", "string"]
313+
},
314+
"unitSize": {
315+
"type": ["null", "integer"]
316+
}
317+
}
318+
},
319+
"isBackOrderAllowed": {
320+
"type": ["null", "boolean"]
321+
},
322+
"netCost": {
323+
"type": ["null", "object"],
324+
"properties": {
325+
"amount": {
326+
"type": ["null", "string"]
327+
},
328+
"currencyCode": {
329+
"type": ["null", "string"]
330+
}
331+
}
332+
},
333+
"listPrice": {
334+
"type": ["null", "object"],
335+
"properties": {
336+
"amount": {
337+
"type": ["null", "string"]
338+
},
339+
"currencyCode": {
340+
"type": ["null", "string"]
341+
}
342+
}
343+
}
344+
}
345+
}
346+
}
347+
}
348+
},
349+
"changedBefore": {
350+
"type": ["null", "string"],
351+
"format": "date-time"
352+
}
353+
}
354+
}

‎airbyte-integrations/connectors/source-amazon-seller-partner/source_amazon_seller_partner/source.py

+2-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,6 @@
33
#
44

55

6-
import traceback
76
from os import getenv
87
from typing import Any, List, Mapping, Optional, Tuple
98

@@ -64,6 +63,7 @@
6463
StrandedInventoryUiReport,
6564
VendorDirectFulfillmentShipping,
6665
VendorInventoryReports,
66+
VendorOrders,
6767
VendorSalesReports,
6868
VendorTrafficReport,
6969
XmlAllOrdersDataByOrderDataGeneral,
@@ -181,6 +181,7 @@ def streams(self, config: Mapping[str, Any]) -> List[Stream]:
181181
FbaInventoryPlaningReport,
182182
LedgerSummaryViewReport,
183183
FbaReimbursementsReports,
184+
VendorOrders,
184185
]
185186

186187
# TODO: Remove after Brand Analytics will be enabled in CLOUD: https://github.com/airbytehq/airbyte/issues/32353

0 commit comments

Comments
 (0)