Тексты объявлений для Авито через API

id,type,name,facts,price,city
B03,б/у,"iPhone 13, 128 ГБ","б/у 2 года; аккумулятор 84%; без сколов; трещина на защитном стекле, экран целый; полный комплект с коробкой; не ремонтировался",38000,Казань
S01,услуга,Ремонт холодильников на дому,"частный мастер; стаж 12 лет; выезд по городу в день обращения; диагностика 500 ₽, бесплатно при ремонте; гарантия на работу 6 месяцев; запчасти привожу с собой",от 1500,Екатеринбург

{
  "id": "S01",
  "title": "Ремонт холодильников на дому, выезд в день обращения",
  "description": "Частный мастер с опытом 12 лет выполняет ремонт холодильников на дому в Екатеринбурге. Выезд по городу в день обращения, запчасти привожу с собой.\n— Выезд и диагностика — 500 ₽, при ремонте диагностика бесплатно.\n— Гарантия на работу — 6 месяцев.\n— Стоимость ремонта — от 1500 ₽.\n— Работаю по Екатеринбургу, выезд в день обращения.\n\nПишите в сообщения на Авито, чтобы вызвать мастера."
}

# write_ads.py — тексты объявлений для Авито из CSV через Polza
import asyncio, csv, json, os, sys
from openai import AsyncOpenAI, APIStatusError

MODEL = "deepseek/deepseek-v4-pro"
PROVIDER = "streamlake/fp8"  # самый дешёвый провайдер модели: top_provider.name в каталоге
CONCURRENCY = 10

ai = AsyncOpenAI(base_url="https://polza.ai/api/v1", api_key=os.environ["POLZA_API_KEY"])
SYSTEM = open("prompt.txt", encoding="utf-8").read()

SCHEMA = {
    "name": "avito_ad",
    "strict": True,
    "schema": {
        "type": "object",
        "properties": {"title": {"type": "string"}, "description": {"type": "string"}},
        "required": ["title", "description"],
        "additionalProperties": False,
    },
}

async def write(row, sem, stats, city=None):
    prompt = (f"Тип: {row['type']}\nНазвание: {row['name']}\nФакты: {row['facts']}\n"
              f"Цена: {row['price']} ₽\nГород: {city or row['city']}")
    if city:  # второе объявление того же товара в другом городе
        prompt += "\nЭто второе объявление того же товара в другом городе: напиши его другими словами, факты те же."
    async with sem:
        for attempt in range(5):
            try:
                r = await ai.chat.completions.create(
                    model=MODEL,
                    messages=[{"role": "system", "content": SYSTEM},
                              {"role": "user", "content": prompt}],
                    response_format={"type": "json_schema", "json_schema": SCHEMA},
                    extra_body={"reasoning": {"effort": "none"},
                                "provider": {"only": [PROVIDER], "allow_fallbacks": False}},
                )
                break
            except APIStatusError as e:
                if e.status_code in (429, 500, 502, 503) and attempt < 4:
                    await asyncio.sleep(2 ** attempt)
                    continue
                raise
    stats["rub"] += r.usage.model_extra.get("cost_rub", 0)
    return {"id": row["id"], "city": city or row["city"], **json.loads(r.choices[0].message.content)}

async def main():
    # python write_ads.py [город для второго варианта]
    second_city = sys.argv[1] if len(sys.argv) > 1 else None
    rows = list(csv.DictReader(open("ads.csv", encoding="utf-8")))
    sem, stats = asyncio.Semaphore(CONCURRENCY), {"rub": 0}
    results = await asyncio.gather(*(write(r, sem, stats, second_city) for r in rows), return_exceptions=True)
    name = "ads_variant.jsonl" if second_city else "ads.jsonl"
    ok = 0
    with open(name, "w", encoding="utf-8") as out, open("errors.txt", "w", encoding="utf-8") as err:
        for row, res in zip(rows, results):
            if isinstance(res, Exception):
                err.write(f"{row['id']}\t{res}\n")
            else:
                out.write(json.dumps(res, ensure_ascii=False) + "\n")
                ok += 1
    print(f"Готово {ok} из {len(rows)}, расход {stats['rub']:.2f} ₽")

asyncio.run(main())