python调用机器人推送消息

from hdfs.client import InsecureClient
from io import StringIO
import pandas as pd
import numpy as np
from tqdm import tqdm
from hdfs import HdfsError
import os


try:
    client = InsecureClient(url="http",user="admin")
    print('r1',client.list('/'))
except HdfsError as e:
    if "Operation category READ is not supported in state standby" in str(e):
        client = InsecureClient(url="http",user="admin")
        print('r2',client.list('/'))
    else:
        print("其他 HdfsError 异常:", e)

names=['pdate','sku','success_membercnt','hb_success_membercnt','success_ordercnt','hb_success_ordercnt','success_totalamount','success_payamount','cancel_membercnt','cancel_ordercnt']
hdfs_file="/ns-traffic/tmp/sku_ontime"
df_data=pd.DataFrame(columns=names)
print(df_data)
for i in tqdm(client.list(hdfs_path=hdfs_file)):
    file_path=hdfs_file+'/'+i
    with client.read(file_path,encoding='utf-8', delimiter=' ') as reader:
        tmp=pd.read_csv(StringIO(' '.join(reader)), sep='x01', names=names)
    df_data=pd.concat([df_data,tmp],axis=0,ignore_index=True)
print(df_data)

    
# 推送内容定位
subset1_1 = df_data.loc[df_data['sku'] == 'x票']
indicator1_1 = subset1_1.iloc[0]['hb_success_ordercnt']
print(indicator1_1)
print(df_data)#上面的print为什么没有打印,下面这个打印

webhook_url = "https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key="
bot = WechatBot(webhook_url)
bot.send_text(content=indicator1_1, mentioned_list=["@all"])
 

关注公众号「水沐教育科技」,在手机上阅读所有教程,随时随地都能学习。内含一款搜索神器,免费下载全网书籍和视频。

公众号二维码
微信扫码关注公众号

微信交流群 关注微信公众号,加入官方交流群。内含一款搜索神器,免费下载全网书籍和视频。