add amazon SDK

Author: vlad-outscraper

outscraper/api_client.py

@@ -477,7 +477,7 @@ def emails_and_contacts(self, query: list, fields: list = None) -> list:
 
                     Parameters:
                             query (list | str): Domains or links (e.g., outscraper.com).
-                            fields (list): parameter defines which fields you want to include with each item returned in the response. By default, it returns all fields.
+                            fields (list): Parameter defines which fields you want to include with each item returned in the response. By default, it returns all fields.
 
                     Returns:
                             list: json result
@@ -516,3 +516,69 @@ def phones_enricher(self, query: list, fields: list = None) -> list:
             return self._wait_request_archive(response.json()['id']).get('data', [])
 
         raise Exception(f'Response status code: {response.status_code}')
+
+    def amazon_products(self, query: Union[list, str], limit: int = 24, fields: list = None, async_request: bool = False, ui: bool = None
+    ) -> Union[list, dict]:
+        '''
+            Returns information about products on Amazon.
+
+                    Parameters:
+                            query (list | str): Amazon product or summary pages URLs.
+                            limit (int): The parameter specifies the limit of products to get from one query (in case of using summary pages).
+                            fields (list): Parameter defines which fields you want to include with each item returned in the response. By default, it returns all fields.
+                            async_request (bool): Parameter defines the way you want to submit your task to Outscraper. It can be set to `False` (default) to send a task and wait until you got your results, or `True` to submit your task and retrieve the results later using a request ID with `get_request_archive`. Each response is available for `2` hours after a request has been completed.
+                            ui (bool): Parameter defines whether a task will be executed as a UI task. This is commonly used when you want to create a regular platform task with API. Using this parameter overwrites the async_request parameter to `True`.
+
+                    Returns:
+                            list: json result
+
+            See: https://app.outscraper.com/api-docs#tag/Amazon/paths/~1amazon~1products/get
+        '''
+        queries = as_list(query)
+        wait_async = async_request or (len(queries) > 1 and limit > 1)
+
+        response = requests.get(f'{self._api_url}/amazon/products', params={
+            'query': queries,
+            'limit': limit,
+            'async': wait_async,
+            'fields': ','.join(fields) if fields else '',
+            'ui': ui,
+        }, headers=self._api_headers)
+
+        return self._handle_response(response, wait_async, async_request)
+
+    def amazon_reviews(self, query: Union[list, str], limit: int = 10, sort: str = 'helpful', filter_by_reviewer: str = 'all_reviews', filter_by_star: str = 'all_stars', fields: list = None, async_request: bool = False, ui: bool = None
+    ) -> Union[list, dict]:
+        '''
+            Returns reviews from Amazon products.
+
+                    Parameters:
+                            query (list | str): You can use URLs or ASINs from Amazon products (e.g., https://www.amazon.com/dp/1612680194, 1612680194, etc.).
+                            limit (int): Parameter specifies the limit of reviews to get from one query.
+                            sort (str): Parameter specifies one of the sorting types. Available values: "helpful", and "recent".
+                            filter_by_reviewer (str): The parameter specifies one of the reviewer filter types (All reviewers / Verified purchase only). Available values: "all_reviews", and "avp_only_reviews".
+                            filter_by_star (str): The parameter specifies one of the filter types by stars. Available values: "all_stars", "five_star", "four_star", "three_star", "two_star", "one_star", "positive", and "critical".
+                            fields (list): Parameter defines which fields you want to include with each item returned in the response. By default, it returns all fields.
+                            async_request (bool): Parameter defines the way you want to submit your task to Outscraper. It can be set to `False` (default) to send a task and wait until you got your results, or `True` to submit your task and retrieve the results later using a request ID with `get_request_archive`. Each response is available for `2` hours after a request has been completed.
+                            ui (bool): Parameter defines whether a task will be executed as a UI task. This is commonly used when you want to create a regular platform task with API. Using this parameter overwrites the async_request parameter to `True`.
+
+                    Returns:
+                            list: json result
+
+            See: https://app.outscraper.com/api-docs#tag/Amazon/paths/~1amazon~1reviews/get
+        '''
+        queries = as_list(query)
+        wait_async = async_request or (len(queries) > 1 and limit > 10)
+
+        response = requests.get(f'{self._api_url}/amazon/reviews', params={
+            'query': queries,
+            'limit': limit,
+            'sort': sort,
+            'filterByReviewer': filter_by_reviewer,
+            'filterByStar': filter_by_star,
+            'async': wait_async,
+            'fields': ','.join(fields) if fields else '',
+            'ui': ui,
+        }, headers=self._api_headers)
+
+        return self._handle_response(response, wait_async, async_request)