| import requests | |
| import os | |
| def search_products(keyword): | |
| url = "https://real-time-amazon-data.p.rapidapi.com/search" | |
| querystring = { | |
| "query": keyword, | |
| "country": "IN" | |
| } | |
| headers = { | |
| "X-RapidAPI-Key": os.getenv("RAPIDAPI_KEY"), | |
| "X-RapidAPI-Host": "real-time-amazon-data.p.rapidapi.com" | |
| } | |
| response = requests.get(url, headers=headers, params=querystring) | |
| return response.json() | |
| def format_products(response): | |
| products = [] | |
| try: | |
| items = response["data"]["products"][:3] | |
| for item in items: | |
| products.append({ | |
| "name": item.get("product_title"), | |
| "price": item.get("product_price"), | |
| "image": item.get("product_photo"), | |
| "link": item.get("product_url") | |
| }) | |
| except: | |
| pass | |
| return products |