python调用华为数据库api进行云数据库访问示例

简介: python调用华为数据库api进行云数据库访问示例
#!/usr/bin/python# -*- coding: UTF-8 -*-fromdli.loggerimportloggerfrompyDLIimportdliimportpandasaspdendpoint="dli.cn-south-1.myhuaweicloud.com"project_id="1f3e574677d54fa893c3bfda48386eff"account="dragon7421"username="chuguoyu"password="sf01394546"ak="9KHRA1FTPVBYNSEJBUIJ"sk="JUxdOhetUKJEOv14ivX5HR8GzvOxcNlA75sBd8qN"queue_name="super_list"database="tpch"defget_connection(auth):
ifauth=='token':
conn=dli.Connection(host="dli://%s/%s?queuename=%s&database=%s"%                                   (endpoint, project_id, queue_name, database),
account=account, username=username, password=password, auth="token")
else:
conn=dli.Connection(host="dli://%s/%s?queuename=%s&database=%s"%                                   (endpoint, project_id, queue_name, database),
ak=ak, sk=sk, auth="aksk")
returnconndefdli_result2dataframe(cursor):
print("job result:")
result_list=cursor.fetchall()
result_list=pd.DataFrame(result_list)
print(result_list)
returnresult_listdefprint_result(cursor):
print("schema info:")
forcol_infoincursor.description:
print("\t%s"% (col_info,))
print("job result:")
result_list=cursor.fetchall()
forrow_datainresult_list:
print("\t%s"%row_data)
print(cursor.rownumber)
defexec_sql(cursor, sql, parameters=None, options=None):
cursor.execute(sql, parameters, options)
returndli_result2dataframe(cursor)
# print_result(cursor)defexec_sql_async(cursor, sql, parameters=None, options=None):
cursor.execute(sql, parameters, options, async_=True)
status=cursor.poll()
whilestatusin ('UNKNOWN', 'LAUNCHING', 'RUNNING'):
logger.info("current job status is: %s"%status)
status=cursor.poll()
print_result(cursor)
defexec_sql_many(cursor, sql, seq_of_parameters):
cursor.executemany(sql, seq_of_parameters)
print_result(cursor)
defmain():
conn=get_connection("aksk")
exec_sql(conn.cursor(), "SELECT * FROM liangfang_car_event_recognition")
exec_sql(conn.cursor(), "INSERT overwrite TABLE liangfang_car_event_recognition  SELECT * FROM liangfang_car_event_recognition limit 5")
exec_sql(conn.cursor(), "SELECT * FROM liangfang_car_event_recognition")
if__name__=='__main__':
main()
目录
相关文章
|
4天前
|
SQL 关系型数据库 MySQL
MySQL数据库子查询——in多个数据查询的示例
MySQL数据库子查询——in多个数据查询的示例
9 1
|
1天前
|
SQL 弹性计算 API
云服务器 ECS产品使用问题之如何通过API调用阿里云服务器上SQL Server数据库中的数据
云服务器ECS(Elastic Compute Service)是各大云服务商阿里云提供的一种基础云计算服务,它允许用户租用云端计算资源来部署和运行各种应用程序。以下是一个关于如何使用ECS产品的综合指南。
|
5天前
|
SQL 存储 关系型数据库
MySQL 示例数据库大全
我们练习 SQL 时,总会自己创造一些测试数据或者网上找些案例来学习,其实 MySQL 官方提供了好几个示例数据库,在 MySQL 的学习、开发和实践中具有非常重要的作用,能够帮助初学者更好地理解和应用 MySQL 的各种功能和特性,特别是练习 SQL 的好帮手。
165 0
|
7天前
|
运维 Serverless API
Serverless 应用引擎产品使用合集之SD API模式可以通过什么方式进行访问
阿里云Serverless 应用引擎(SAE)提供了完整的微服务应用生命周期管理能力,包括应用部署、服务治理、开发运维、资源管理等功能,并通过扩展功能支持多环境管理、API Gateway、事件驱动等高级应用场景,帮助企业快速构建、部署、运维和扩展微服务架构,实现Serverless化的应用部署与运维模式。以下是对SAE产品使用合集的概述,包括应用管理、服务治理、开发运维、资源管理等方面。
|
8天前
|
SQL Java 数据库
Java一分钟之-Spring Data JPA:简化数据库访问
【6月更文挑战第10天】Spring Data JPA是Spring Data项目的一部分,简化了Java数据库访问。它基于JPA,提供Repository接口,使开发者能通过方法命名约定自动执行SQL,减少代码量。快速上手包括添加相关依赖,配置数据库连接,并定义实体与Repository接口。常见问题涉及主键生成策略、查询方法命名和事务管理。示例展示了分页查询的使用。掌握Spring Data JPA能提升开发效率和代码质量。
29 0
|
10天前
|
数据采集 JSON 算法
使用Python爬取华为市场APP应用进行分析
这个网站也是作者最近接触到的一个APP应用市场类网站。讲实话,还是蛮适合新手朋友去动手学习的。毕竟爬虫领域要想进步,还是需要多实战、多分析!该网站中的一些小细节也是能够锻炼分析能力的,也有反爬虫处理。甚至是下载APP的话在Web端是无法拿到APK下载的直链,需要去APP端接口数据获取
|
10天前
|
机器学习/深度学习 数据采集 文字识别
印刷文字识别产品使用合集之需要对子用户加什么权限,才能通过API访问
印刷文字识别产品,通常称为OCR(Optical Character Recognition)技术,是一种将图像中的印刷或手写文字转换为机器编码文本的过程。这项技术广泛应用于多个行业和场景中,显著提升文档处理、信息提取和数据录入的效率。以下是印刷文字识别产品的一些典型使用合集。
|
12天前
|
存储 SQL 关系型数据库
MySQL数据库——存储过程-介绍以及基本语法(特点、创建、调用、查看、删除、示例)
MySQL数据库——存储过程-介绍以及基本语法(特点、创建、调用、查看、删除、示例)
16 0
|
12天前
|
SQL 关系型数据库 MySQL
MySQL数据库——视图-介绍及基本语法(创建、查询、修改、删除、演示示例)
MySQL数据库——视图-介绍及基本语法(创建、查询、修改、删除、演示示例)
27 0
|
14天前
|
人工智能 自然语言处理 API
利用Python调用KimiGPT API接口
Kimi作为国内目前广受欢迎的AI工具,因其出色的性能和智能功能,迅速赢得了大量用户的青睐。随着用户量的激增,系统在高峰时段可能会面临响应压力。正是借助这一热潮,Kimi团队适时推出了其API服务,使用户和开发者能够更加灵活和深入地集成和使用Kimi的智能功能。

热门文章

最新文章