【小程序】008 基于云函数获取数据并去重插入云数据库

node -v
npm -v

npm install --save request
npm install --save request-promise

由于request-promise依赖于request，所以两者安装顺序不能改变

const rp = require('request-promise');

• npm 依赖：若云函数中有使用到 npm 模块，需在云函数本地目录安装相应依赖才可正常使用云函数本地调试功能。

  const playlist = await rp(URL).then((res) => {
    return JSON.parse(res).data.list
  })
  console.log(playlist)

  for(let i = 0,len = playlist.length; i < len; i++){
    await db.collection("playlist").add({
      data:{
        ...playlist[i],
        createTime: db.serverDate(),
      }
    }).then((res)=>{
      console.log("插入成功")
    }).catch((err)=>{
      console.error("插入失败")
    })
  }

createTime: db.serverDate(),

  const dbList = await playlistCollection.get()//获取云数据库数据

创建一个数组用于存放识别出来的未重复歌单

  const newData = []

循环遍历：

  for(let i = 0,len1 = playlist.length; i < len1; i++){
    let flag = true//标志位，true表不重复
    for(let j = 0,len2 = dbList.data.length;j < len2; j++)
      if(playlist[i].specialid === dblist.data[j].specialid){
        flag = false
        break//重复则直接结束本次数据库的遍历
      }
      if(flag){
        newData.push(playlist[i])
      }
  }

// 云函数入口文件
const cloud = require('wx-server-sdk')

cloud.init()

const db = cloud.database()

const rp = require('request-promise')

const URL = "服务端接口"

const playlistCollection = db.collection("playlist")

// 云函数入口函数
exports.main = async (event, context) => {
  const dbList = await playlistCollection.get()//获取云数据库数据
  const playlist = await rp(URL).then((res) => {//获取服务端数据
    return JSON.parse(res).data.list
  })

  const newData = []
  for(let i = 0,len1 = playlist.length; i < len1; i++){
    let flag = true//标志位，true表不重复
    for(let j = 0,len2 = dbList.data.length;j < len2; j++)
      if(playlist[i].specialid === dbList.data[j].specialid){
        flag = false
        break//重复则直接结束本次数据库的遍历
      }
      if(flag){
        newData.push(playlist[i])
      }
  }

  for(let i = 0,len = newData.length; i < len; i++){
    await playlistCollection.add({
      data:{
        ...newData[i],
        createTime: db.serverDate(),
      }
    }).then((res)=>{
      console.log("插入成功")
    }).catch((err)=>{
      console.error("插入失败")
    })
  }

  return newData.length
}

https://music.163.com/api/playlist/detail?id=2557908184 

http://mobilecdnbj.kugou.com/api/v5/special/recommend?recommend_expire=0&sign=52186982747e1404d426fa3f2a1e8ee4&plat=0&uid=0&version=9108&page=1&area_code=1&appid=1005&mid=286974383886022203545511837994020015101&_t=1545746286
使用技巧：
 
limit：返回数据条数(每页获取的数量)，默认为20，可以自行更改
 
offset：偏移量(翻页)，offset需要是limit的倍数
 
type：搜索的类型
 
举例，比如limit设置为10，则第一页，第二页分别为：
 
http://music.163.com/api/v1/resource/comments/R_SO_4_483671599?limit=10&offset=0
 
http://music.163.com/api/v1/resource/comments/R_SO_4_483671599?limit=10&offset=10PS:返回的数据格式为json，需要注意的是通过此接口获取的评论数量最多2万条。

$ git clone git@github.com:Binaryify/NeteaseCloudMusicApi.git

$ npm install

提醒没有文件夹，我们进入clone下来的文件夹再执行

运行

$ node app.js

http://localhost:3000/

http://localhost:3000/playlist/highquality/tags

服务器启动默认端口为 3000, 若不想使用 3000 端口 , 可使用以下命令 : Mac/Linux

$ PORT=4000 node app.js

windows 下使用 git-bash 或者 cmder 等终端执行以下命令 :

$ set PORT=4000 && node app.js

服务器启动默认 host 为localhost,如果需要更改, 可使用以下命令 : Mac/Linux

$ HOST=127.0.0.1 node app.js

windows 下使用 git-bash 或者 cmder 等终端执行以下命令 :

$ set HOST=127.0.0.1 && node app.js