外部库

阅读(2869) 标签: 函数, 数据库,

本章主要介绍常用的外部库相关函数。

Ø  ali_client()

连接阿里云,结果返回成游标

Ø  ali_close()

关闭阿里云连接

Ø  ali_query()

范围查询,结果返回成游标

Ø  es_close()

关闭elasticsearch服务器连接

Ø  es_delete()

执行delete指令

Ø  es_head()

执行head指令

Ø  es_get()

执行get指令

Ø  es_open()

连接elasticsearch(简称ES)服务器

Ø  es_post()

执行post指令

Ø  es_put()

执行put指令

Ø  ftp_cd()

设置ftp服务器上的远程工作目录

Ø  ftp_client()

创建ftp客户端

Ø  ftp_close()

关闭ftp客户端

Ø  ftp_dir()

列出ftp服务器当前目录下的所有文件和目录

Ø  ftp_get()

ftp服务器下载单个文件

Ø  ftp_mget()

ftp服务器下载多个文件

Ø  ftp_mput()

上传多个文件到ftp服务器

Ø  ftp_put()

上传单个文件到ftp服务器

Ø  hbase_close()

关闭hbase数据库连接

Ø  hbase_cmp()

通过hbase比较器筛选数据

Ø  hbase_filter()

通过hbase过滤器筛选数据

Ø  hbase_filterlist()

多个过滤器组合过滤数据

Ø  hbase_get()

查询hbase数据库中的数据,结果值返回一行记录

Ø  hbase_open()

创建hbase数据库连接

Ø  hbase_scan()

查询hbase数据库中的数据,结果值返回游标或者序表

Ø  hdfs_client()

连接hdfs文件系统,返回HdfsClient对象

Ø  hdfs_close()

关闭hdfs连接

Ø  hdfs_dir()

列出指定路径下的文件名称

Ø  hdfs_file()

打开指定的目录,返回HdfsFile对象

Ø  hive_client()

创建Hive数据库连接

Ø  hive_close()

关闭Hive数据库连接

Ø  hive_cursor()

查询Hive数据库,结果值返回成游标

Ø  hive_execute()

执行sql语句

Ø  hive_query()

查询Hive数据库,结果值返回成序列

Ø  ifx_close()

关闭Informix数据库连接

Ø  ifx_conn()

创建Informix数据库连接

Ø  ifx_ cursor()

以游标的形式列出指定表的分片信息

Ø  ifx_listfrag()

以序表的形式列出指定表的分片信息

Ø  ifx_savefrag()

将内存中的分片信息并存入文件

Ø  ifx_setfrag()

设置表table的分片信息

Ø  ifx_takefrag()

从数据库提取指定表的分片信息

Ø  influx_close()

关闭influxdb数据库

Ø  influx_insert()

influxdb中插入数据

Ø  influx_open()

连接influxdb数据库

Ø  influx_query()

查询influxdb数据库

Ø  kafka_close()

关闭consumer连接

Ø  kafka_commit()

提交当前consumer offset的位置

Ø  kafka_poll()

获取consumer消息记录, 返回序表

Ø  kafka_subscribe()

连接kafka server服务器

Ø  mongo_close()

关闭mongo数据库连接

Ø  mongo_insert()

mongo中插入数据

Ø  mongo_open()

连接mongodb服务器

Ø  mongo_shell()

查询数据库,返回结果值

Ø  olap_close()

关闭多维数据库连接

Ø  olap_open()

创建多维数据库连接

Ø  olap_query()

查询多维数据库,返回结果值

Ø  redis_close()

关闭数据库连接

Ø  redis_exists()

判断是否存在key

Ø  redis_expire()

给指定键设置过滤时间

Ø  redis_get()

获取key所关联的字符串值

Ø  redis_getbit()

判断指定位置的ASCII码的bit位是否为1

Ø  redis_getrange()

获取key中字符串值的子字符串

Ø  redis_hexists()

查看哈希表中的指定字段是否存在

Ø  redis_hkeys()

key不存在时,不返回表

Ø  redis_hmget()

获取哈希表key中,一个或多个给定域的值

Ø  redis_hscan()

迭代哈希表中的键值配对

Ø  redis_hsize()

获取哈希表中字段的数量

Ø  redis_hvals()

获取哈希表key中所有域的值

Ø  redis_increment()

给指定键中所储存的值加上指定的整数或数值

Ø  redis_keys()

查找所有符合给定模式patternkey

Ø  redis_lindex()

获取列表key中,下标为index的元素

Ø  redis_lrange()

获取列表key中指定区间内的元素

Ø  redis_lsize()

获取列表key的长度

Ø  redis_ltrim()

裁剪列表指定范围内的元素

Ø  redis_open()

连接redis数据库

Ø  redis_persist()

移除给定的过期时间

Ø  redis_randomkey()

从当前数据库中随机返回一个key

Ø  redis_sdiff()

获取一个集合的全部成员,该集合是所有给定集合之间的差集

Ø  redis_sinter()

一个集合的全部成员,该集合是所有给定集合的交集

Ø  redis_sismember()

判断member元素是否是集合key的成员

Ø  redis_size()

获取key储存的字符串的长度

Ø  redis_smembers()

获取集合 key 中的所有成员

Ø  redis_sscan()

迭代集合中键的元素

Ø  redis_srandmember()

获取集合中的随机元素

Ø  redis_sunion()

获取一个集合的全部成员,该集合是所有给定集合的并集

Ø  redis_type()

获取key所储存的值的类型

Ø  redis_zcard()

获取有序集key的基数

Ø  redis_zcount()

获取有序集key中,score值在minmax之间的成员的数量

Ø  redis_zrange()

返回有序集key中,指定区间内的成员

Ø  redis_zrangebyscore()

获取有序集key中,指定区间的成员

Ø  redis_zrank()

获取有序集key中成员member的排名

Ø  redis_zscan()

迭代有序集合中的元素

Ø  redis_zscore()

获取有序集key中,成员memberscore

Ø  redis_zsize()

获取有序集合中的数据条数

Ø  report_config()

读取配置文件信息

Ø  report_exportHtml()

将报表导出为Html或者Mht文件

Ø  report_exportPdf()

将报表导出为pdf文件

Ø  report_exportXls()

将报表导出为xlsxlsx文件

Ø  report_open()

读取报表文件

Ø  report_run()

计算报表

Ø  sap_open()

创建Sap服务连接

Ø  sap_close()

关闭Sap服务连接

Ø  sap_cursor()

通过游标形式获取table结果集列表

Ø  sap_excute()

根据输入的参数获取function对象

Ø  sap_getparam()

根据输入的参数获取数据记录

Ø  sap_table()

根据输入的Table参数获取数据列表

Ø  sf_close()

关闭通过rest api方式连接的Salesforce server云服务器

Ø  sf_open()

通过rest api方式连接Salesforce server云服务器

Ø  sf_query()

查询数据并返回结果值

Ø  sf_wsdlclose()

关闭通过soap api方式连接的Salesforce server云服务器

Ø  sf_wsdlopen()

通过soap api方式连接Salesforce server云服务器

Ø  sf_wsdlquery()

查询数据并返回结果值

Ø  sf_wsdlview()

查询Sobject对象数据,返回字段名与字段类型组成的序表

Ø  spark_client()

创建Spark数据库连接

Ø  spark_close()

关闭Spark数据库连接

Ø  spark_cursor()

查询Spark数据库,结果值返回成游标

Ø  spark_query()

查询Spark数据库,结果值返回成序列

Ø  stax_close()

关闭Cassandra数据库连接

Ø  stax_connect()

创建Cassandra数据库连接

Ø  stax_query()

查询Cassandra数据库,结果值返回成序表

Ø  ws_call()

创建webservice客户端

Ø  ws_client()

webservice服务器发送请求,获取服务器返回的数据

Ø  ym_build_model()

执行建模操作

Ø  ym_close()

释放资源

Ø  ym_env()

设置环境变量,初始化环境

Ø  ym_exec()

执行python文件

Ø  ym_importance()

获取模型变量的重要度列表

Ø  ym_json()

将模型信息以json串形式返回

Ø  ym_load_pcf()

根据模型文件生成模型对象

Ø  ym_model()

加载建模用的数据

Ø  ym_performance()

获取模型表现信息

Ø  ym_predict()

根据模型文件生成模型对象

Ø  ym_present()

获取模型描述信息

Ø  ym_result()

通过模型对象和预测数据产生预测结果

Ø  ym_save_pcf()

根据模型对象生成模型文件

Ø  ym_setparam()

设置建模参数

Ø  ym_server_quit()

关闭python服务

Ø  ym_statistics()

获取统计变量的相关信息

Ø  ym_target()

设置目标变量

Ø  zip()

实现zip的各种功能

Ø  zip_add()

zip文件内增加文件

Ø  zip_close()

关闭zip文件

Ø  zip_compress()

设置zip文件的压缩模式和级别

Ø  zip_del()

zip压缩文件中删除指定文件

Ø  zip_encrypt()

设置zip的加密模式

Ø  zip_extract()

zip压缩文件中抽取指定文件

Ø  zip_open()

打开zip文件