pyleus 无法将结果写入MySQL数据库

问题描述

pyleus 无法将结果写入MySQL数据库

我在requirements.txt文件中写了MySQLdb的库MySQL-python，并且拓扑能够被顺利的build生成jar包，但是当我把jar
包提交以后，出现如下错误信息：

 11814 [Thread-12-result-count] ERROR backtype.storm.daemon.executor - java.lang.RuntimeException: Error when launching multilang subprocessTraceback (most recent call last):  File ""/usr/lib64/python2.7/runpy.py"" line 162 in _run_module_as_main__main__"" fname loader pkg_name)  File ""/usr/lib64/python2.7/runpy.py"" line 72 in _run_code    exec code in run_globals  File ""/tmp/e16601e5-a293-4233-bb9e-0e68090a44d6/supervisor/stormdist/association-miner-1-1462975821/resources/association-miner/result.py"" line 2 in <module>    import MySQLdbImportError: No module named MySQLdb

我的yaml文件配置如下：

name: association-miner

topology:

- spout:    name: trans-spout    module: association-miner.spout- bolt:    name: mining    module: association-miner.mining    parallelism_hint: 3    groupings:        - shuffle_grouping: trans-spout- bolt:    name: result-count    module: association-miner.result    groupings:        - global_grouping: mining

解决方案

问题已解决除了在requirements.txt中写‘MySQL-python’，在集群各个节点上也要安装MySQL-python

时间： 2024-04-19 07:54:18

pyleus 无法将结果写入MySQL数据库的相关文章

PHP通过SQL语句将数据写入MySQL数据库指定的表

PHP向MySQL数据库中写入数据有三个步骤: 1,PHP和MySQL建立连接关系 2,打开MySQL数据库 3,接受页面数据,PHP录入到指定的表中 1.2两步可直接使用一个数据库链接文件即可:conn.php <?php mysql_connect("localhost","root","");//连接MySQL mysql_select_db("hello");//选择数据库 ?> 当然,前提是已经安装WEB

如何把日志写入数据库-如何把日志写入mysql数据库（日志就是记录项目中的所有操作）

问题描述如何把日志写入mysql数据库(日志就是记录项目中的所有操作) 我在mysql中建了表,字段有:操作者ID.操作者姓名.模块名称.操作类型.IP地址.MAC地址.操作时间.查询条件.日志详细内容其中 "查询条件" 指用户在系统中,如果用 "查询" 操作时输入的查询条件:IP地址.MAC地址是用户机器使用的ip 和 mac 地址:操作类型暂时有这么几项:使用业务功能.浏览.查询.登入.登出....搞不清的都归为使用业务功能 ,然后在日志详细内容中说

Php连接及读取和写入mysql数据库的常用代码_php技巧

既然现在你看到了这篇文章,说明你肯定知道PHP和MySQL是怎么一回事,我就不啰嗦了.但为什么你还要继续阅读此文呢?可能是以前你习惯复制粘贴一些代码,并没有真正弄懂代码的含义:也可能你以前弄懂了,但像我一样,有一段时间没有接触,生疏了:再或者,有人问你类似的简单问题,而你已经不屑于回答,直接上网搜索,恰好找到了这篇,于是就推荐给那谁谁谁了... 不管怎样,在这里我总结了常用的PHP连接MySQL数据库以及读取写入数据库的方法,希望能够帮到你,当然也是作为我自己的一个回顾总结. 1.为了更好地设置

PHP表单数据写入MySQL数据库的代码_php实例

废话不多说了,直接给大家贴代码了,具体代码如下所示: <h插入操作</h <?php if(!isset($_POST['submit'])){ //如果没有表单提交,显示一个表单 ?> <form action="" method="post"> 国家:<input type="text" name="country" /> 动物名称(英文):<input type=&q

快速把Apache访问日志实时写入mysql数据库

在apache配置文件或是虚拟主机配置文件中(也就是配置LogFormat以及CustomLog部分)增加如下内容: LogFormat "INSERT INTO apachelog (ID, dateTime, IP, URL, code, referer, userAgent, size, request) VALUES ( NULL , ＼"%{%Y-%m-%d %H:%M:%S}t＼", ＼"%a＼", ＼"%U＼", ＼&qu

将TXT中天气预报内容写入MYSQL数据库

package com.zzk.cn; import java.io.*; import java.sql.*; import java.util.*; public class TxtToMysql { /** * @param args * 本程序涉及文件IO,字符串分隔StringTokenizer,JDBC,数据库sql语句 */ public static void main(String[] args) { Connection con = null; PreparedState

PHP数据写入MySql数据库

<?php // 数据库服务器IP或地址 $mysql_server_name='localhost'; // 数据库用户名 $mysql_username='demo'; // 数据库密码 $mysql_password='K8q7N4M7'; // 数据库名 $mysql_database='demo'; // 连接数据库 $conn=mysql_connect($mysql_server_name,$mysql_username,$mysql_password); // 判断连接是

php写入mysql数据库信息为乱码

代码如下复制代码 mysql_query("set names 'utf8′"); 先设置写入的编码如果设置好编码后就不会出现乱码问题. php设置网页编码代码如下复制代码 header("Content-Type:text/html;charset=utf-8″); 这里就是设置成utf-8格式: 把utf-8改成gb2312就变成了简体中文的了.如果进行开发还是建意使用utf-8比较好. php 对 IP及IP段进行访问限制的代码 192.168.1.1 单个

使用Perl连接Mysql数据库

网站后台数据库转为Mysql,现在使用Perl连接数据库就方便多了. 通过DBI,Perl可以很容易的连接到数据库: #!/bin/perl use DBI; # Connect to target DBmy $dbh = DBI->connect("DBI:mysql:database=eygle;host=localhost","username","password", {'RaiseError' => 1}); # Inser