iepy-develop/iepy/selfpreprocess/BiddingKG/dl/interface/2.py

'''
Created on 2019年8月6日

@author: User
'''
from BiddingKG.dl.common.Utils import save,load
import requests
import json

import redis
import BiddingKG.dl.interface.settings as settings

# 连接redis数据库
db = redis.StrictRedis(host=settings.REDIS_HOST, port=settings.REDIS_PORT,
                       db=6,password=settings.REDIS_PASS)

def test(name,content):
    user = {
            "content": content,
            "id":name
            }
    myheaders = {'Content-Type': 'application/json'}
    _resp = requests.post("http://192.168.2.101:15015" + '/article_extract', json=user, headers=myheaders, verify=True)
    resp_json = _resp.content.decode("utf-8")
    print(resp_json)
    return resp_json

if __name__=="__main__":
    
    queue = load("err.pk")
    print(queue)
    data = json.loads(queue[1].decode())
    _data = data["content"]
    print(_data)
    test("12",_data)
    '''
    print(2)
    while(True):
        queue = db.blpop(settings.ERROR_QUEUE)
        if queue:
            print(3)
            break
    save(queue,"err.pk")
    '''