http://www.sufeinet.com/plugin.php?id=keke_group

苏飞论坛

 找回密码
 马上注册

QQ登录

只需一步,快速开始

分布式系统框架(V2.0) 轻松承载百亿数据,千万流量!讨论专区 - 源码下载 - 官方教程

HttpHelper爬虫框架(V2.7-含.netcore) HttpHelper官方出品,爬虫框架讨论区 - 源码下载 - 在线测试和代码生成

HttpHelper爬虫类(V2.0) 开源的爬虫类,支持多种模式和属性 源码 - 代码生成器 - 讨论区 - 教程- 例子

查看: 8603|回复: 3

[python基础] python多线程加锁提交百度原创接口实现连接mssql版

[复制链接]
发表于 2022-1-22 10:36:50 | 显示全部楼层 |阅读模式
上次的文章是不带访问数据库的
python多线程循环加锁实现高速提交百度优化原创接口
http://www.sufeinet.com/thread-41362-1-1.html



不多说和上次一样直接上代码
[Python] 纯文本查看 复制代码
# This is a sample Python script.

# Press Shift+F10 to execute it or replace it with your code.
# Press Double Shift to search everywhere for classes, files, tool windows, actions, and settings.
import _thread
import datetime
import hashlib
import pprint
import string
import struct
import threading
import time
import urllib

import requests
import pymssql, os


count = 1   # 声明全局变量
lock = threading.Lock()  # 申请一把锁
def postcurl(i):
    print("线程",i,"启动")
    global count  # 引用全局变量
    while count < 10:
        url = 'http://data.zz.baidu.com/urls?site=tool.sufeinet.com&token=你的密匙'
        headers = {
            'Content-Type': 'text/plain',
            'User-Agent': 'curl/7.12.1',
            'Referer': "http://tool.sufeinet.com"
        }

        lock.acquire()  # 加锁

        server = "ip"  # 服务器IP或服务器名称
        user = "sa"  # 登陆数据库所用账号
        password = "pwd"  # 该账号密码
        conn = pymssql.connect(server, user, password, database='数据库名')
        cursor = conn.cursor()
        cursor.execute(" SELECT * FROM tablename where com_id="+count.__str__())  # 向数据库发送SQL命令
        row = cursor.fetchone()
        curl = "http://tool.sufeinet.com/Encrypt/MD5.aspx?action=Decode&md5str="
        while row:

            curl=curl+urllib.parse.quote(row[1])

            row = cursor.fetchone()
            conn.close()

        count += 1
        lock.release()  # 释放锁

        # 获取数据
        str_html = requests.post(url, data=curl, headers=headers)

        # 输出获取到的 as html
        print("线程", i, "正在执行:", str_html.text + "__" + curl)
    print("循环结束")


# 主方法,程序的开始
if __name__ == '__main__':

    try:
        for i in range(1, 2):
            time.sleep(1)
            _thread.start_new_thread(postcurl, (i,))
    except:
        print("Error: 无法启 动线程")
    while 1:
        pass



1. 开通SVIP会员,免费下载本站所有源码,不限次数据,不限时间
2. 加官方QQ群,加官方微信群获取更多资源和帮助
3. 找站长苏飞做网站、商城、CRM、小程序、App、爬虫相关、项目外包等点这里
 楼主| 发表于 2022-1-24 16:29:14 | 显示全部楼层
[Python] 纯文本查看 复制代码
# This is a sample Python script.

# Press Shift+F10 to execute it or replace it with your code.
# Press Double Shift to search everywhere for classes, files, tool windows, actions, and settings.
import _thread
import datetime
import hashlib
import pprint
import string
import struct
import threading
import time
import urllib

import requests
import pymssql, os

count = 10050000  # 声明全局变量
lock = threading.Lock()  # 申请一把锁

def postcurl(i):
    print("线程", i, "启动")
    global count  # 引用全局变量

    while count < 10200000:
        url = 'http://data.zz.baidu.com/urls?site=tool.sufeinet.com&token=密匙'
        headers = {
            'Content-Type': 'text/plain',
            'User-Agent': 'curl/7.12.1',
            'Referer': "http://tool.sufeinet.com"
        }

        # 加锁
        lock.acquire()
        count += 1
        # 释放锁
        lock.release()

        # 服务器IP或服务器名称
        server = "ip"
        # 登陆数据库所用账号
        user = "sa"
        # 该账号密码
        password = "pwd"
        conn = pymssql.connect(server, user, password, database='数据库名')
        cursor = conn.cursor()
        # 向数据库发送SQL命令
        cursor.execute("SELECT * FROM tablename where com_id=" + count.__str__())
        row = cursor.fetchone()
        curl = "http://tool.sufeinet.com/Encrypt/MD5.aspx?action=Decode&md5str="
        while row:
            curl = curl + urllib.parse.quote(row[1])
            # 获取数据
            str_html = requests.post(url, data=curl, headers=headers)
            # 输出获取到的 as html
            print("线程", i, "正在执行:", str_html.text, "-",row[1], "__", count)
            row = cursor.fetchone()

    print("循环结束")
    conn.close()

# 主方法,程序的开始
if __name__ == '__main__':

    try:
        for i in range(1, 10):
            time.sleep(1)
            _thread.start_new_thread(postcurl, (i,))
    except:
        print("Error: 无法启 动线程")
    while 1:
        pass

回复 支持 1 反对 0

使用道具 举报

 楼主| 发表于 2022-1-24 15:15:25 | 显示全部楼层
[Python] 纯文本查看 复制代码
# This is a sample Python script.

# Press Shift+F10 to execute it or replace it with your code.
# Press Double Shift to search everywhere for classes, files, tool windows, actions, and settings.
import _thread
import datetime
import hashlib
import pprint
import string
import struct
import threading
import time
import urllib

import requests
import pymssql, os

count = 10019000  # 声明全局变量
lock = threading.Lock()  # 申请一把锁

def postcurl(i):
    print("线程", i, "启动")
    global count  # 引用全局变量
    # 服务器IP或服务器名称
    server = "ip"
    # 登陆数据库所用账号
    user = "sa"
    # 该账号密码
    password = "pwd"
    conn = pymssql.connect(server, user, password, database='数据库名')
    while count < 10200000:
        url = 'http://data.zz.baidu.com/urls?site=tool.sufeinet.com&token=你的密匙'
        headers = {
            'Content-Type': 'text/plain',
            'User-Agent': 'curl/7.12.1',
            'Referer': "http://tool.sufeinet.com"
        }

        # 加锁
        lock.acquire()

        cursor = conn.cursor()
        # 向数据库发送SQL命令
        cursor.execute("SELECT * FROM tablename where com_id=" + count.__str__())
        row = cursor.fetchone()
        curl = "http://tool.sufeinet.com/Encrypt/MD5.aspx?action=Decode&md5str="
        while row:
            curl = curl + urllib.parse.quote(row[1])
            # 获取数据
            str_html = requests.post(url, data=curl, headers=headers)
            # 输出获取到的 as html
            print("线程", i, "正在执行:", str_html.text, "-",row[1], "__", curl)
            row = cursor.fetchone()

        count += 1

        # 释放锁
        lock.release()
    print("循环结束")
    conn.close()

# 主方法,程序的开始
if __name__ == '__main__':

    try:
        for i in range(1, 10):
            time.sleep(1)
            _thread.start_new_thread(postcurl, (i,))
    except:
        print("Error: 无法启 动线程")
    while 1:
        pass

您需要登录后才可以回帖 登录 | 马上注册

本版积分规则

QQ|手机版|小黑屋|手机版|联系我们|关于我们|广告合作|苏飞论坛 ( 豫ICP备18043678号-2)

GMT+8, 2024-4-15 13:42

© 2014-2021

快速回复 返回顶部 返回列表