Flink使用指南 Flink flink-bos-hadoop是百度云对象存储系统BOS针对 Flink 的文件系统实现,并且支持了 recoverwriter 接口,Flink 可以基于该文件系统实现读写 BOS 上的数据以及作为流应用的状态后端。 安装 1.Flink环境准备 以1.15.0版本为例。
异常处理 BOS异常提示有如下四种方式: 异常方法 说明 BceBaseException 异常总集 BceClientException 客户端异常 BceServerException 服务器异常 InvalidArgumentException 系统自带异常,参数错误 用户可以使用try获取某个事件所产生的异常: deleteObject(\$bucketName, \$objectKey);
计费模式 BOS回收站不另外收费,回收站内的文件还视为Bucket内数据的一部分,按照其存储类型收取容量费用。 当回收站内的文件被彻底清除后,将不收取容量费用。
version\ :\ v1\ ,\ customHeaders\ :[],\ storageClass\ :\ STANDARD\ , + \ ignoreHeaders\ :[],\ passHeaders\ :[]}]} ; // 请求 this . client . putBucketMirroring ( bucketName , configJson ) ; 获取镜像回源配置
边缘存储类 BEC边缘存储功能是怎么使用? 用户可以在BEC控制台使用边缘存储功能。BEC支持创建边缘对象存储和云磁盘。 BEC边缘对象存储功能是怎么使用? 用户可以在BEC控制台通过创建bucket来使用该功能,创建完成之后,用户可以上传文件或者文件夹到bucket。 BEC边缘对象存储怎么计费? 边缘对象存储根据用户使用量计费。 BEC边缘对象存储有几种权限?
否 fetch模式下回源存储类型,例如STANDARD 字符串 passHeaders 透传的header 否 请求源站时将透传的header 列表 ignoreHeaders 忽略的header 否 请求源站时将忽略的header 列表 customHeaders 自定义header 否 请求源站时自定义携带的header 列表 响应(Response) 响应示例 HTTP/1.1 200 OK
如下代码可获取一个对象的访问权限: s = bos_get_object_acl ( options , & bucket , & object , & root , & resp_headers ) ; * jsonString = json_dumps ( root , JSON_INDENT ( 2 ) ) ; printf ( \n%s\n , jsonString
权限相关接口 创建权限组中的权限 描述 在特定的存储网关权限组中 创建一个权限 请求结构 POST /v{version}/auth&authGroupId={authGroupId} HTTP/1.1 Host: bsg.bj.baidubce.com Authorization: authorization string { "authGroupId": authGroupId
查看文件列表 概述 当创建 Bucket 之后,您可以查看所拥有的 Bucket 列表,还可以从 BOS 中获取指定 Bucket 的 Object 信息列表,BOS 同时支持使用API 与使用 SDK 列出 Bucket 和 Object。
对返回的对象可以调用执行getLocation()/getName()获取Bucket所在区域和Bucket名字。