数据导入导出操作
数据的导入、导出任务一旦成功建立,结果将以邮件的形式发送到企业创建者的邮箱中。
通过 数据表 ID
或 数据表名
实例化一个 TableObject
对象,以下操作都是在该对象上进行操作:
let MyTableObject = new BaaS.TableObject(tableID)
参数说明
参数名 | 类型 | 说明 |
---|---|---|
tableID | integer | 数据表的 ID |
数据导出
MyTableObject.exportData(fileType, mode, start, end)
参数说明
参数 | 类型 | 必填 | 说明 |
---|---|---|---|
fileType | String | 是 | 导出文件的格式,支持 csv、json、xlsx 格式 |
mode | String | 是 | 导出任务的模式 |
start | Integer / Date / String | 否 | 导出部分数据的起始时间 |
end | Integer / Date / String | 否 | 导出部分数据的结束时间 |
导出任务支持两种模式:
值 | 说明 |
---|---|
all | 导出全部数据 |
part | 导出部分数据 |
示例代码
exports.main = async function exportData() {
try {
let MyTableObject = new BaaS.TableObject(tableID)
let res = await MyTableObject.exportData('json', 'all')
// success
return res
} catch(err) {
// error
throw err
}
}
function exportData() {
let MyTableObject = new BaaS.TableObject(tableID)
MyTableObject.exportData('json', 'all').then(res => {
// success
callback(null, res)
}).catch(err => {
// error
callback(err)
})
}
返回示例 (res.status === 200)
res.data:
{
"status": "ok"
}
数据导入
MyTableObject.importData({dataFileUrl, dataFilePath}, fileType)
参数说明
参数 | 类型 | 必填 | 说明 |
---|---|---|---|
dataFileUrl | String | 否 | 准备导入的备份数据 url (dataFileUrl 与 dataFile 两者必须指定一个) |
dataFile | String / Buffer | 否 | 文件路径(目前仅支持沙箱环境的 tmp 目录) / 文件 Buffer |
fileType | String | 是 | 导入文件的格式,支持 csv、json、xlsx 格式 |
示例代码
exports.main = async function importData() {
try {
/* url */
let MyTableObject = new BaaS.TableObject(tableID)
let res = await MyTableObject.importData({dataFileUrl: dataUrl}, 'csv')
// success
/* 本地文件路径 */
const fs = require('fs')
const file = fs.createWriteStream('/tmp/data.csv')
let res = await BaaS.request.get(dataUrl)
file.write(res.data)
file.end()
let MyTable = new BaaS.TableObject(tableID)
let importRes = await MyTable.importData({dataFile: '/tmp/data.csv'}, 'csv')
// success
return res
/* Buffer */
let res = await BaaS.request.get(dataUrl)
let MyTable = new BaaS.TableObject(tableID)
let importRes = await MyTable.importData({dataFile: Buffer.from(res.data)}, 'csv')
// success
return res
} catch(err) {
// error
throw err
}
}
function importData() {
/* url */
let MyTableObject = new BaaS.TableObject(tableID)
MyTableObject.importData({dataFileUrl: dataUrl}, 'csv').then(res => {
// success
callback(null, res)
}).catch(err => {
// error
callback(err)
})
/* 本地文件路径 */
const fs = require('fs')
const file = fs.createWriteStream('/tmp/data.csv')
BaaS.request.get(dataUrl).then(res => {
file.write(res.data)
file.end()
let MyTable = new BaaS.TableObject(tableID)
MyTable.importData({dataFile: '/tmp/data.csv'}, 'csv').then(res => {
// success
callback(null, res)
}).catch(err => {
// error
callback(err)
})
})
/* Buffer */
BaaS.request.get(dataUrl).then(res => {
let MyTable = new BaaS.TableObject(tableID)
MyTable.importData({dataFile: Buffer.from(res.data)}, 'csv').then(res => {
// success
callback(null, res)
}).catch(err => {
// error
callback(err)
})
})
}
返回示例 (res.status === 200)
res.data:
{
"status": "ok"
}