impala 将查询数据导出为文件格式

谁借莪１个温暖的怀抱￠ 2024-03-17 13:28 94阅读 0赞

#### 文章目录 ####

*   *  用impala-shell 命令行将查询的结果导出到本地文件
 *  总结

--------------------

### 用impala-shell 命令行将查询的结果导出到本地文件 ###

impala-shell -q  "select * from table limit 10" -B --output_delimiter="\t" -o testimpalaoutput.txt

**例1**

impala-shell -i dn01:21000 -B --output_delimiter=',' -q "select * from position.cttic_vehicleposition_202302_1 limit 20 " -o vehPos.csv

**例2\[后台执行impala-shell\]**

nohup impala-shell -i dn01:21000 -B --output_delimiter=',' -q "SELECT md5(concat(vehicleno, 'bs')) AS vehicleno, vec1 , CAST(lon / 1000000.0 AS decimal(20, 4)) AS lon, CAST(lat / 1000000.0 AS decimal(20, 4)) AS lat, positiontime FROM position.cttic_vehicleposition_202307_1 WHERE curaccesscode = 310113 UNION ALL SELECT md5(concat(vehicleno, 'bs')) AS vehicleno, vec1 , CAST(lon / 1000000.0 AS decimal(20, 4)) AS lon, CAST(lat / 1000000.0 AS decimal(20, 4)) AS lat, positiontime FROM position.cttic_vehicleposition_202307_2 WHERE curaccesscode = 310113 UNION ALL SELECT md5(concat(vehicleno, 'bs')) AS vehicleno, vec1 , CAST(lon / 1000000.0 AS decimal(20, 4)) AS lon, CAST(lat / 1000000.0 AS decimal(20, 4)) AS lat, positiontime FROM position.cttic_vehicleposition_202307_3 WHERE curaccesscode = 310113 UNION ALL SELECT md5(concat(vehicleno, 'bs')) AS vehicleno, vec1 , CAST(lon / 1000000.0 AS decimal(20, 4)) AS lon, CAST(lat / 1000000.0 AS decimal(20, 4)) AS lat, positiontime FROM position.cttic_vehicleposition_202307_4 WHERE curaccesscode = 310113 " -o vehBSPos.csv > output.log 2>&1 &

**impala-shell 还有其他很多参数，可以impala-shell -h 查看，下面是别人翻译的，copy过来供大家参考 ：**

<table> 
 <thead> 
  <tr> 
   <th align="left">选项</th> 
   <th align="left">描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="left">-B or –delimited</td> 
   <td align="left">导致使用分隔符分割的普通文本格式打印查询结果。当为其他 Hadoop 组件生成数据时有用。对于避免整齐打印所有输出的性能开销有用，特别是使用查询返回大量的结果集进行基准测试的时候。使用 –output_delimiter 选项指定分隔符。使用 -B 选项常用于保存所有查询结果到文件里而不是打印到屏幕上。在 Impala 1.0.1 中添加</td> 
  </tr> 
  <tr> 
   <td align="left">–print_header</td> 
   <td align="left">是否打印列名。整齐打印时是默认启用。同时使用 -B 选项时，在首行打印列名</td> 
  </tr> 
  <tr> 
   <td align="left">-o filename or –output_file filename</td> 
   <td align="left">保存所有查询结果到指定的文件。通常用于保存在命令行使用 -q 选项执行单个查询时的查询结果。对交互式会话同样生效；此时你只会看到获取了多少行数据，但看不到实际的数据集。当结合使用 -q 和 -o 选项时，会自动将错误信息输出到 /dev/null(To suppress these incidental messages when combining the -q and -o options, redirect stderr to /dev/null)。在 Impala 1.0.1 中添加</td> 
  </tr> 
  <tr> 
   <td align="left">–output_delimiter=character</td> 
   <td align="left">当使用 -B 选项以普通文件格式打印查询结果时，用于指定字段之间的分隔符(Specifies the character to use as a delimiter between fields when query results are printed in plain format by the -B option)。默认是制表符 tab (‘\t’)。假如输出结果中包含了分隔符，该列会被引起且/或转义( If an output value contains the delimiter character, that field is quoted and/or escaped)。在 Impala 1.0.1 中添加</td> 
  </tr> 
  <tr> 
   <td align="left">-p or –show_profiles</td> 
   <td align="left">对 shell 中执行的每一个查询，显示其查询执行计划 (与 EXPLAIN 语句输出相同) 和发生低级故障(low-level breakdown)的执行步骤的更详细的信息</td> 
  </tr> 
  <tr> 
   <td align="left">-i hostname or –impalad=hostname</td> 
   <td align="left">指定连接运行 impalad 守护进程的主机。默认端口是 21000。你可以连接到集群中运行 impalad 的任意主机。假如你连接到 impalad 实例通过 –fe_port 标志使用了其他端口，则应当同时提供端口号，格式为 hostname:port</td> 
  </tr> 
  <tr> 
   <td align="left">-q query or –query=query</td> 
   <td align="left">从命令行中传递一个查询或其他 shell 命令。执行完这一语句后 shell 会立即退出。限制为单条语句，可以是 SELECT, CREATE TABLE, SHOW TABLES, 或其他 impala-shell 认可的语句。因为无法传递 USE 语句再加上其他查询，对于 default 数据库之外的表，应在表名前加上数据库标识符(或者使用 -f 选项传递一个包含 USE 语句和其他查询的文件)</td> 
  </tr> 
  <tr> 
   <td align="left">-f query_file or –query_file=query_file</td> 
   <td align="left">传递一个文件中的 SQL 查询。文件内容必须以分号分隔</td> 
  </tr> 
  <tr> 
   <td align="left">-k or –kerberos</td> 
   <td align="left">当连接到 impalad 时使用 Kerberos 认证。如果要连接的 impalad 实例不支持 Kerberos，将显示一个错误</td> 
  </tr> 
  <tr> 
   <td align="left">-s kerberos_service_name or –kerberos_service_name=name</td> 
   <td align="left">Instructs impala-shell to authenticate to a particular impalad service principal. 如何没有设置 kerberos_service_name ，默认使用 impala。如何启用了本选项，而试图建立不支持 Kerberos 的连接时，返回一个错误(If this option is used in conjunction with a connection in which Kerberos is not supported, errors are returned)</td> 
  </tr> 
  <tr> 
   <td align="left">-c</td> 
   <td align="left">查询执行失败时继续执行</td> 
  </tr> 
  <tr> 
   <td align="left">-r or –refresh_after_connect</td> 
   <td align="left">建立连接后刷新 Impala 元数据，与建立连接后执行 REFRESH 语句效果相同</td> 
  </tr> 
  <tr> 
   <td align="left">-d default_db or –database=default_db</td> 
   <td align="left">指定启动后使用的数据库，与建立连接后使用 USE 语句选择数据库作用相同，如果没有指定，那么使用 default 数据库</td> 
  </tr> 
  <tr> 
   <td align="left">-l</td> 
   <td align="left">启用 LDAP 认证</td> 
  </tr> 
  <tr> 
   <td align="left">-u</td> 
   <td align="left">当使用 -l 选项启用 LDAP 认证时，提供用户名(使用短用户名，而不是完整的 LDAP 专有名称(distinguished name)) ，shell 会提示输入密码</td> 
  </tr> 
 </tbody> 
</table>

--------------------

## 总结 ##

> 如果此篇文章有帮助到您, 希望打大佬们能`关注`、`点赞`、`收藏`、`评论`支持一波，非常感谢大家！  
> 如果有不对的地方请指正!!!

[参考1][1]

[1]: https://blog.csdn.net/jobschen/article/details/68942574