import timeimport threadingimport pandas as pdfrom woocommerce import API

wcapi = API(    url="https://xxxx",    consumer_key="AAA",    consumer_secret="AAA",    wp_api=True,    timeout=60,    version="wc/v3")

for index, row in df.iterrows():    data = {        'name': row['name'],          'type': row['type'],          'sku': str(row['isbn']),          'regular_price': str(row['price']),          'description': row['description'],          'categories': [{'name': row['categories']}],          'images': [{'src': row['image']}],         'status': row['status'],          'catalog_visibility': row['visibility'],         'tax_status': row['tax_status'],          'weight': str(row['weight']),          'dimensions': {            'length': str(row['length']),              'width': str(row['width']),                'height': str(row['height'])           },        'manage_stock': True,          'stock_quantity': int(row['stock']),      }

product_lock = threading.Lock()def create_or_update_product(wcapi, row, data):    max_retries = 3    retry_delay = 5        with product_lock:        for attempt in range(max_retries):            produtos_existentes = wcapi.get("products", params={'sku': row['isbn']}).json()                        if produtos_existentes and isinstance(produtos_existentes, list) and len(produtos_existentes) > 0:                produto_id = produtos_existentes[0]['id']                resultado_atualizacao = wcapi.put(f"products/{produto_id}", data).json()                if 'id' in resultado_atualizacao:                    print(f"Produto {row['name']} atualizado com sucesso! ID: {resultado_atualizacao['id']}")                    return                else:                    print(f"Erro ao atualizar o produto {row['name']}: {resultado_atualizacao}")                    if attempt < max_retries - 1:                        print(f"Tentando novamente em {retry_delay} segundos...")                        time.sleep(retry_delay)            else:                resultado_criacao = wcapi.post("products", data).json()                if 'id' in resultado_criacao:                    print(f"Produto {row['name']} criado com sucesso! ID: {resultado_criacao['id']}")                    return                elif resultado_criacao.get('code') == 'woocommerce_rest_product_not_created' and 'already under processing' in resultado_criacao.get('message', ''):                    print(f"Produto {row['name']} está sendo processado. Tentando novamente em {retry_delay} segundos...")                    time.sleep(retry_delay)                else:                    print(f"Erro ao criar o produto {row['name']}: {resultado_criacao}")                    returnif row['isbn']:    create_or_update_product(wcapi, row, data)