Function create_ip_pool

proxy/proxy_ip_pool.py:198–218

Create IP proxy pool :param ip_pool_count: Number of IPs in the pool :param enable_validate_ip: Whether to enable IP proxy validation :return:

(ip_pool_count: int, enable_validate_ip: bool)

async def create_ip_pool(ip_pool_count: int, enable_validate_ip: bool) -> ProxyIpPool:
    """
    Create IP proxy pool
    :param ip_pool_count: Number of IPs in the pool
    :param enable_validate_ip: Whether to enable IP proxy validation
    :return:
    """
    ip_provider = IpProxyProvider.get(config.IP_PROXY_PROVIDER_NAME)
    if ip_provider is None:
        raise ValueError(
            f"Unknown proxy provider: '{config.IP_PROXY_PROVIDER_NAME}'. "
            f"Valid options: {list(IpProxyProvider.keys())}"
        )
    is_static = config.IP_PROXY_PROVIDER_NAME == ProviderNameEnum.STATIC_PROVIDER.value
    pool = ProxyIpPool(
        ip_pool_count=ip_pool_count,
        enable_validate_ip=False if is_static else enable_validate_ip,
        ip_provider=ip_provider,
    )
    await pool.load_proxies()
    return pool


if __name__ == "__main__":