import base64
import uuid

from base.utils.kafka_helper import producer_myself


def transfer(item):
    # 安卓的比较特殊，异步下发url至url爬虫
    uuid_str = str(uuid.uuid4())
    news_id = base64.b64encode(bytes(item["url"], encoding='utf8')).decode()
    item['news_id'] = news_id
    producer_myself("aic.spider.url", {"news_id": news_id, "uuid": uuid_str, "url": item['url'], "type": "phone",
                                       "source": item.get("source")})