大家好,欢迎来到IT知识分享网。
def write_data(param):
print >> sys.stderr , ( “test
the stderr”)
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.connect((param[“ip”], param[“port”]))
fd = sock.fileno()
# login
w_login_pack = ul_pack_ex.ul_pack_init()
ul_pack_ex.ul_pack_putvalue(w_login_pack,”Sender”,”Distribution”)
ul_pack_ex.ul_pack_putvalue(w_login_pack,”Request”,”LOGIN”)
ul_pack_ex.ul_pack_putbuf(w_login_pack,”NULL”,0)
ret2 = ul_pack_ex.ul_pack_writeo_ms(fd, w_login_pack,
1000)
rpack = ul_pack_ex.ul_pack_init()
if ret2 < 0:
print >> sys.stderr,(‘write wdb
login return error! ret=%d’%ret2)
quit()
else:
ret2 = ul_pack_ex.ul_pack_reado_ms(fd, rpack, 1000)
ack_write =
ul_pack_ex.ul_pack_getvalue_refer(rpack,”Response”)
if ack_write != ‘OK’:
print >> sys.stderr,(‘write wdb
login ack error! ack=%s’% ack_write)
quit()
# build write_prepare_pack
write_prepare_pack = ul_pack_ex.ul_pack_init()
ul_pack_ex.ul_pack_putvalue(write_prepare_pack, “Sender”,
“Distribution”);
ul_pack_ex.ul_pack_putvalue(write_prepare_pack, “Method”,
“MOD”);
ul_pack_ex.ul_pack_putvalue(write_prepare_pack, “Feature”,
“NULL”);
ul_pack_ex.ul_pack_putvalue(write_prepare_pack, “Codetype”,
“GB”);
ul_pack_ex.ul_pack_putvalue(write_prepare_pack, “Ip-region”,
“0”);
ul_pack_ex.ul_pack_putvalue(write_prepare_pack, “Net-region”,
“0”);
ul_pack_ex.ul_pack_putvalue(write_prepare_pack,
“Last-mod-time”, “0”);
ul_pack_ex.ul_pack_putvalue(write_prepare_pack, “Category”,
“0”);
ul_pack_ex.ul_pack_putvalue(write_prepare_pack, “Pageweight”,
“0”);
ul_pack_ex.ul_pack_putvalue(write_prepare_pack, “Version”,
“1”);
ul_pack_ex.ul_pack_putvalue(write_prepare_pack, “Sexfactor”,
“0”);
ul_pack_ex.ul_pack_putvalue(write_prepare_pack,
“Politicalfactor”, “0”);
ul_pack_ex.ul_pack_putvalue(write_prepare_pack, “Titlelength”,
“0”);
ul_pack_ex.ul_pack_putvalue(write_prepare_pack,
“Contentlength”, “0”);
ul_pack_ex.ul_pack_putvalue(write_prepare_pack, “Linklength”,
“0”);
ul_pack_ex.ul_pack_putvalue(write_prepare_pack, “Title”,
“”);
ul_pack_ex.ul_pack_putvalue(write_prepare_pack,
“Pubtime”, “”);
write_dict[“url”] = param[“url”]
content = getContent(param[“content”])
write_dict[“Content”] = content
write_dict[“page”] = content
# build mcpack
write_mcpack = mcpack.dumps_version(mcpack.mcpackv1,
write_dict, 512*1024)
print ‘mcpack.dumps_version succeed’
ul_pack_ex.ul_pack_putvalue(write_prepare_pack, “Url”,
param[“url”].encode(“utf8”));
lenth = sys.getsizeof(write_mcpack)
ul_pack_ex.ul_pack_putvalue(write_prepare_pack, “Pagelength”,
str(lenth));
ul_pack_ex.ul_pack_putbuf(write_prepare_pack,write_mcpack,lenth)
# send mcpack to webdb
ret2 = ul_pack_ex.ul_pack_writeo_ms(fd, write_prepare_pack,
1000)
if ret2 <0:
print ‘write wdb write data error! ret=%d’%ret2
quit()
else:
write_count = 0
print ‘write succeed’
免责声明:本站所有文章内容,图片,视频等均是来源于用户投稿和互联网及文摘转载整编而成,不代表本站观点,不承担相关法律责任。其著作权各归其原作者或其出版社所有。如发现本站有涉嫌抄袭侵权/违法违规的内容,侵犯到您的权益,请在线联系站长,一经查实,本站将立刻删除。 本文来自网络,若有侵权,请联系删除,如若转载,请注明出处:https://haidsoft.com/153362.html