本地数据迁移到BOS 对象存储（BOS）
您把数据拷贝到硬盘上后，请把硬盘寄送到下面地址： 地址 北京市房山区窦店镇广茂路37号 光环新网数据中心 电话 16619934602 联系人 BJDD 机房 硬盘寄回的地址，可以联系客户经理告知我们的接口人。硬盘寄送请选择保价，邮费请自负，寄回去时也会选择到付。北京同城1天，异地一般2天内可达。硬盘寄回之前，按照百度安全要求会统一清空硬盘，请关注。
Spark 使用指南 对象存储（BOS）
PATH : $HADOOP_HOME /bin: $SPARK_HOME /bin 2.添加依赖 jar 包 下载 BOS-HDFS # 解压，拷贝到spark依赖路径 unzip bos-hdfs-sdk-1.0.3-community.jar.zip cp bos-hdfs-sdk-1.0.3-community.jar { SPARK_HOME } /jars # 访问BOS的一些必要配置
Bucket生命周期管理 对象存储（BOS）
生命周期管理就是对象存储服务帮助用户自动化管理数据的生命周期。 通常可以服务于以下场景： 数据达到一定寿命后自动归档或删除。 指定时间执行操作。 新建Lifecycle配置 基本流程 创建BosClient。
安装SDK工具包 对象存储（BOS）
客户端入口类 │ ├──bos_handle.py //HTTP reponse处理函数 │ ├──canned_acl.py //权限控制需要的常量 │ └──storage_class.py //存储类型定义模块 ├── bce_base_client.py //BCE客户端入口类的基类 ├── bce_client_configuration.py //针对BOS特有的HttpClient的配置类
GetBucketCors 对象存储（BOS）
如果有多条配置，执行顺序为从上到下。 是 无 allowedOrigins 存储允许的跨域请求的来源的容器。 是 corsConfiguration allowedOrigin 指定允许的跨域请求的来源，允许使用最多一个 * 通配符。 如果指定为 * 则表示允许所有的来源的跨域请求。特别的还支持 * 作为后缀来表示某一类网站比如 abc* ，则表示支持abc开头的网站。
设置Bucket存储类型 对象存储（BOS）
设置Bucket存储类型 新建的Bucket默认是标准存储类型，用户也可以通过如下代码设置或获取指定Bucket的存储类型： 参数 说明 storageClass 存储类型，支持 STANDARD 、 STANDARD_IA 、 COLD 、 ARCHIVE public void PutBucketStorageClass ( ) { // 设置 STANDARD_IA ，低频存储 String
PutBucketVersioning 对象存储（BOS）
PutBucketVersioning 接口描述 调用PutBucketVersioning设置指定存储空间（Bucket）的版本控制状态。 注意事项 要配置版本控制，您必须有PutBucketVersioning权限。 Bucket包括未开启(notEnabled)、开启（enabled）或者暂停（suspended）三种版本控制状态。默认情况下Bucket处于未开启版本控制状态。
数据目的地 - 物联网核心套件IoTCore | 百度智能云文档
操作流程 例如规则引擎订阅接收到如下消息： { temperature : 36.2 } 假设目的地是名称为广州区域下的kafka主题device2service 应用服务器通过消费device2service主题可实时处理设备数据，当服务器故障时，kafka中未消费的数据可以在服务恢复后继续处理。
操作步骤 - 物联网核心套件IoTCore | 百度智能云文档
key 可选，可指定规则输出结果中的JSON对象最外层的一个key作为写入Kafka的key值 特别注意： 消息写入目的地时，写入性能受目的地云产品限制，当写入速率超过目的地云产品性能限制时可能触发目的地产品限制导致写入失败，写入失败的消息将被丢弃，请务必确保经过规则过滤每秒写入目的地产品的TPS和吞吐在目的地产品允许范围之内。
设置Bucket数据同步 对象存储（BOS）
bucket_name/<生效的对象前缀>｝，必须要以$bucket_name+/开头 destination Destination 是 复制的目的端配置 replicateHistory ReplicateHistory 否 历史文件复制，有该项则认为是开启。
