实现图表组件的方法及装置

    公开(公告)号:CN108492346A

    公开(公告)日:2018-09-04

    申请号:CN201810224254.X

    申请日:2018-03-19

    发明人: 陆峰 黄彬 覃江

    IPC分类号: G06T11/20

    摘要: 本发明公开实现图表组件的方法及装置,包括:根据预定的图表类型绘制对应图表,生成与图表类型相对应的图表数据;针对各个图表类型创建对应的图表组件,所述图表组件在传入的图表数据变化时根据所述图表数据重新绘制图表;根据图表类型将所生产的图表数据传入对应的图表组件;将各个类型的图表组件进行发布。本发明能够针对定制的图表类型生成图表组件,在图表组件发布后,项目可应用图表组件进行绘制,满足了较高定制的图表绘制的要求,并节约了开发成本。

    语音日志分析方法和系统

    公开(公告)号:CN108416041A

    公开(公告)日:2018-08-17

    申请号:CN201810210420.0

    申请日:2018-03-14

    发明人: 龚静 肖通 陆峰

    IPC分类号: G06F17/30 G10L15/22 G10L15/30

    摘要: 本发明公开语音日志分析方法及装置,其中,方法包括:收集日志并存储在日志仓库;从日志仓库中提取对于用户音频信息的响应时间超过阈值的第一日志;将第一日志确定为异常日志,并将触发日志异常的用户音频信息标记为异常音频信息。本发明能够在互联网大数据背景下,依托大数据技术对语音日志进行分析和挖掘,从而可以从不同的维度对日志数据进行分析,以得到不同维度下的异常日志,从而尽可能地挖掘出潜在的问题。进一步地,后续可以对不同维度下的异常日志进行不同的处理,以达到对语音对话模型的优化,从而更好地应用于各种语音对话场景。

    为客户提供对话服务的方法及装置

    公开(公告)号:CN108418981B

    公开(公告)日:2019-10-29

    申请号:CN201810219667.9

    申请日:2018-03-16

    发明人: 肖通 陆峰 黄彬

    IPC分类号: H04M3/51 H04M3/493 G10L15/06

    摘要: 本发明公开为客户提供对话服务的方法及装置,方法包括:响应于客户的对话请求,启用智能对话服务功能为所述客户提供对话服务;根据预设算法监测所述对话服务的质量,生成服务质量评分;判断所述服务质量评分是否低于第一预设阈值;当所述服务质量评分低于所述第一预设阈值时,通知人工处理平台为所述客户提供对话服务。本发明实施例能够对对话进行实时监控,在智能对话服务功能与客户对话出现问题时,做到及时发现并转由人工进行处理,进而提高了对话的服务质量,并且可以在紧急情况下,避免因智能对话服务功能无法解决客户问题而造成严重后果。

    用于任务调度系统的日志阻塞解决方法及系统

    公开(公告)号:CN109376015A

    公开(公告)日:2019-02-22

    申请号:CN201811239421.4

    申请日:2018-10-23

    IPC分类号: G06F9/50

    摘要: 本发明公开一种用于任务调度系统的日志阻塞解决方法,包括:从任务调度系统的元数据中获取执行任务信息;根据所述执行任务信息确定需要启动以执行的任务;基于所述需要启动以执行的任务生成消息队列;启动多个子进程从所述消息队列中的拉取消息以执行相应任务,并进行日志处理及输出。本发明实施例中多进程的配合使用可以均摊单节点的日志压力,同时单节点的日志量可以避开节点的pipe瓶颈,从而有效解决了现有技术中所存在的日志堵塞问题。

    一种大数据端到端的数据质量监控方法和装置

    公开(公告)号:CN108494590A

    公开(公告)日:2018-09-04

    申请号:CN201810213377.3

    申请日:2018-03-15

    发明人: 陆峰 黄彬 覃江

    IPC分类号: H04L12/24

    摘要: 本发明公开一种大数据的端到端的数据质量监控方法、装置、电子设备及存储介质,该方法包括:将大数据处理流程中各阶段的数据质量统计上报给监控系统;监控系统将收集的数据质量进行分析处理,判断是否需要告警,并将需要告警的告警信息发送给告警系统;告警系统对告警信息分析处理后进行告警操作,并将分析处理后的告警信息发送至工单系统;工单系统接收所述告警信息,下发工单。该系统包括相互连接的监控系统,告警系统,工单系统。本发明实现了大数据端到端的数据质量监控,引入工单系统,通过将告警信息发送至工单系统,检测到问题后基于模型进行实时告警处理,然后自动接入工单系统通知到对应的人进行处理,真正做到监与控的结合。

    数据采集方法、数据采集平台、客户端及业务服务器

    公开(公告)号:CN108491499B

    公开(公告)日:2020-03-06

    申请号:CN201810228757.4

    申请日:2018-03-20

    发明人: 陆峰 黄彬 覃江

    IPC分类号: G06F16/20 G06F16/90

    摘要: 本发明公开一种数据采集方法、数据采集平台、客户端及业务服务器,所述方法包括:基于主动数据采集服务,采集业务服务器中的结构化数据和对应于所述结构化数据的第一日志信息;基于被动数据采集服务,接收客户端所发送的与所述结构化数据相关的非结构化数据和对应于所述非结构化数据的第二日志信息,其中所述第一日志信息与所述第二日志信息相互关联;基于所述第一日志信息和所述第二日志信息,关联存储所述结构化数据和所述非结构化数据。本发明实施例的数据采集的方法将非结构化数据和结构化数据进行关联存储,实现了对非结构化数据的被动数据采集,且混合实施了主动数据采集和被动数据采集,提高了数据收集的效率。

    为客户提供对话服务的方法及装置

    公开(公告)号:CN110519472A

    公开(公告)日:2019-11-29

    申请号:CN201910912515.1

    申请日:2018-03-16

    发明人: 肖通 陆峰 黄彬

    IPC分类号: H04M3/51 H04M3/493 G10L15/06

    摘要: 本发明公开为客户提供对话服务的方法及装置,方法包括:响应于客户的对话请求,启用智能对话服务功能为所述客户提供对话服务;根据预设算法监测所述对话服务的质量,生成服务质量评分;判断所述服务质量评分是否低于第一预设阈值;当所述服务质量评分低于所述第一预设阈值时,通知人工处理平台为所述客户提供对话服务。本发明实施例能够对对话进行实时监控,在智能对话服务功能与客户对话出现问题时,做到及时发现并转由人工进行处理,进而提高了对话的服务质量,并且可以在紧急情况下,避免因智能对话服务功能无法解决客户问题而造成严重后果。

    用于spark streaming的资源动态分配和反馈方法及装置

    公开(公告)号:CN109684077A

    公开(公告)日:2019-04-26

    申请号:CN201811482797.8

    申请日:2018-12-05

    IPC分类号: G06F9/50

    CPC分类号: G06F9/5027 G06F9/5083

    摘要: 本发明公开用于spark streaming的资源动态分配和反馈方法及装置,方法包括:响应于首次接收的spark streaming任务数据流,计算处理spark streaming任务数据流需要使用的初始资源并向资源管理器发送初始资源使用申请,其中,初始资源对应多台处理设备;基于接收的与初始资源对应的多台处理设备反馈的运行时指标数据,计算多台处理设备的负载情况;至少基于多台处理设备的负载情况,周期性地计算与spark streaming任务数据流对应的动态分配资源并向资源管理器发送动态资源分配申请。本申请的方案能够实现资源的动态扩缩容,减少人工进行干预,实现资源的动态精准分配和调整。

    基于语义理解的搜索方法、系统、电子设备及存储介质

    公开(公告)号:CN108920666A

    公开(公告)日:2018-11-30

    申请号:CN201810730301.8

    申请日:2018-07-05

    发明人: 肖通 陆峰

    IPC分类号: G06F17/30

    摘要: 本发明公开一种基于语义理解的搜索方法、系统、电子设备及存储介质,其中,所述方法包括:预先采用无监督自适应训练方法训练语义理解模型;根据用户输入内容确定用于输入至所述语义理解模型的文本内容;所述语义理解模型基于所述文本内容确定用户搜索意图;确定相应于所述用户搜索意图的搜索结果推送给用户。本发明实施例由于通过引入语义理解模型来确定用户进行搜索的真实意图,从而能够获取真正是用户想要的搜索结果,避免了传统搜索方法为用户推荐过多内容,降低了用户获取想要的搜索结果的时间成本、精力成本,提升了用户体验。

    用于spark streaming的资源动态分配方法和系统

    公开(公告)号:CN109684078A

    公开(公告)日:2019-04-26

    申请号:CN201811482798.2

    申请日:2018-12-05

    IPC分类号: G06F9/50 G06F9/455

    摘要: 本发明公开用于spark streaming的资源动态分配方法和系统,方法包括:响应于首次接收的spark streaming任务数据流,获取spark streaming任务数据流的第一数据;基于第一数据计算处理spark streaming任务数据流需要使用的初始资源,并向资源管理器发送初始资源使用申请;周期性地采集当前运行进程运行时的第二数据,基于第二数据计算需要增加或减少的运行进程的第二数量;基于运行进程的第二数量向资源管理器发送动态资源分配申请以动态增加或减少第二数量的运行进程。本申请实施例提供的方案可以本申请的方案能够实现资源的动态扩缩容,减少人工进行干预,实现资源的动态精准分配和调整。