index.js 1.3 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556
  1. const cloud = require('wx-server-sdk');
  2. cloud.init({
  3. env: cloud.DYNAMIC_CURRENT_ENV
  4. });
  5. const db = cloud.database();
  6. // 创建集合云函数入口函数
  7. exports.main = async (event, context) => {
  8. try {
  9. // 创建集合
  10. await db.createCollection('sales');
  11. await db.collection('sales').add({
  12. // data 字段表示需新增的 JSON 数据
  13. data: {
  14. region: '华东',
  15. city: '上海',
  16. sales: 11
  17. }
  18. });
  19. await db.collection('sales').add({
  20. // data 字段表示需新增的 JSON 数据
  21. data: {
  22. region: '华东',
  23. city: '南京',
  24. sales: 11
  25. }
  26. });
  27. await db.collection('sales').add({
  28. // data 字段表示需新增的 JSON 数据
  29. data: {
  30. region: '华南',
  31. city: '广州',
  32. sales: 22
  33. }
  34. });
  35. await db.collection('sales').add({
  36. // data 字段表示需新增的 JSON 数据
  37. data: {
  38. region: '华南',
  39. city: '深圳',
  40. sales: 22
  41. }
  42. });
  43. return {
  44. success: true
  45. };
  46. } catch (e) {
  47. // 这里catch到的是该collection已经存在,从业务逻辑上来说是运行成功的,所以catch返回success给前端,避免工具在前端抛出异常
  48. return {
  49. success: true,
  50. data: 'create collection success'
  51. };
  52. }
  53. };