Как использовать отзывы покупателей как канал продаж на маркетплейсах: пошаговый план

{
 "review_id": "12345",
 "product_id": "98765",
 "rating": 4,
 "title": "Хороший товар",
 "body": "Качество соответствует описанию, но упаковка могла бы быть лучше.",
 "date": "2024-03-15T14:23:00Z",
 "order_id": "54321",
 "sentiment": "positive"
}

Привет, {{name}}! 
Спасибо за заказ №{{order_id}}. 
Как вам {{product_name}}? 
Оставьте отзыв: {{review_link}} 
С уважением, команда {{brand}}

<script type="application/ld+json">
{
 "@context": "https://schema.org",
 "@type": "Product",
 "name": "Кофейный набор «Экспрессо»",
 "aggregateRating": {
 "@type": "AggregateRating",
 "ratingValue": "4.7",
 "ratingCount": "128"
 },
 "review": [
 {
 "@type": "Review",
 "author": { "@type": "Person", "name": "Алексей" },
 "datePublished": "2024-04-12",
 "reviewRating": { "@type": "Rating", "ratingValue": "5" },
 "description": "Отличный набор, быстро готовится и вкусен."
 },
 {
 "@type": "Review",
 "author": { "@type": "Person", "name": "Мария" },
 "datePublished": "2024-04-10",
 "reviewRating": { "@type": "Rating", "ratingValue": "4" },
 "description": "Хороший вкус, но упаковка могла быть лучше."
 }
 ]
}
</script>

import requests, json, os, logging, datetime

logging.basicConfig(filename='update_reviews.log',
 level=logging.INFO,
 format='%(asctime)s %(levelname)s %(message)s')

API_KEY = os.getenv('API_KEY')
BASE = 'https://api.marketplace.com/v1'

def fetch_reviews(product_id):
 url = f'{BASE}/products/{product_id}/reviews'
 headers = {'Authorization': f'Bearer {API_KEY}'}
 resp = requests.get(url, headers=headers, timeout=10)
 resp.raise_for_status()
 return resp.json()

def build_description(reviews):
 lines = []
 for r in reviews:
 lines.append(f"- {r['rating']}★: {r['text'][:100]}...")
 return "\n".join(lines)

def update_product_page(product_id, description):
 payload = {'description': description}
 url = f'{BASE}/products/{product_id}'
 headers = {'Authorization': f'Bearer {API_KEY}',
 'Content-Type': 'application/json'}
 resp = requests.put(url, headers=headers, json=payload, timeout=10)
 resp.raise_for_status()

if __name__ == '__main__':
 product_id = '12345'
 try:
 reviews = fetch_reviews(product_id)
 desc = build_description(reviews)
 update_product_page(product_id, desc)
 logging.info('Обновление завершено успешно')
 except Exception as e:
 logging.error(f'Ошибка обновления: {e}')