Flutter项目如何将JSON数据导入Firestore或从Firebase实时数据库迁移

你提供的源实时数据库结构：

目标Firestore结构：

下面提供两种可直接落地的实现方案：

方案一：直接导入原始JSON到Firestore（无需经过实时数据库中转，推荐） #

你本身做Flutter开发，直接用Dart写临时导入脚本最方便，步骤如下：

• 确认项目已引入firebase_core和cloud_firestore依赖，临时将Firestore权限调整为测试可写（导入完成后改回正式规则即可）
• 将待导入的JSON文件放入项目assets目录，或直接转换为Dart Map对象
• 执行如下一次性导入函数：

import 'package:firebase_core/firebase_core.dart';
import 'package:cloud_firestore/cloud_firestore.dart';
import 'package:flutter/services.dart' show rootBundle;
import 'dart:convert';

Future<void> importJsonToFirestore() async {
  await Firebase.initializeApp();
  final firestore = FirebaseFirestore.instance;
  
  // 读取本地asset中的JSON文件
  final jsonString = await rootBundle.loadString('assets/你的数据文件.json');
  final List<dynamic> dataList = json.decode(jsonString);

  // 使用批量写入提升效率，Firestore单批量上限为500条操作
  WriteBatch batch = firestore.batch();
  int count = 0;
  const int batchLimit = 500;

  for (var item in dataList) {
    // 可自定义文档ID，比如用数据中的id字段，也可留空自动生成
    DocumentReference docRef = firestore.collection('目标集合名称').doc(item['id'].toString());
    batch.set(docRef, item as Map<String, dynamic>);
    count++;

    if (count % batchLimit == 0) {
      await batch.commit();
      batch = firestore.batch();
    }
  }
  // 提交剩余不足500条的数据
  if (count % batchLimit != 0) {
    await batch.commit();
  }
  print('导入完成，共写入 $count 条数据');
}

• 导入完成后删除临时代码，恢复Firestore安全规则即可。

方案二：从已有的实时数据库迁移数据到Firestore #

如果你已经把JSON上传到了实时数据库，可以直接迁移同时删除源数据：

• 项目额外引入firebase_database依赖
• 执行如下迁移函数：

import 'package:firebase_core/firebase_core.dart';
import 'package:cloud_firestore/cloud_firestore.dart';
import 'package:firebase_database/firebase_database.dart';

Future<void> migrateRtdbToFirestore() async {
  await Firebase.initializeApp();
  final rtdbRef = FirebaseDatabase.instance.ref('源数据在实时数据库的节点路径');
  final firestore = FirebaseFirestore.instance;

  // 读取实时数据库全量数据
  final snapshot = await rtdbRef.get();
  if (!snapshot.exists) {
    print('未找到源数据');
    return;
  }

  final Map<dynamic, dynamic> sourceData = snapshot.value as Map;
  WriteBatch batch = firestore.batch();
  int count = 0;
  const int batchLimit = 500;

  sourceData.forEach((rtdbKey, value) {
    // 可直接用实时数据库的节点名作为Firestore文档ID，也可自定义
    DocumentReference docRef = firestore.collection('目标集合名称').doc(rtdbKey);
    batch.set(docRef, Map<String, dynamic>.from(value));
    count++;

    if (count % batchLimit == 0) {
      await batch.commit();
      batch = firestore.batch();
    }
  });

  if (count % batchLimit != 0) {
    await batch.commit();
  }

  // 迁移完成后删除实时数据库源数据
  await rtdbRef.remove();
  print('迁移完成，共迁移 $count 条数据，源数据已从实时数据库删除');
}

注意事项 #

• 如果数据中包含时间字段，建议导入时转换为Firestore的Timestamp类型，方便后续按时间查询
• 首次导入建议先拿少量测试数据验证结构是否匹配目标Firestore结构，确认无误后再全量导入
• 批量写入不要超过500条的限制，避免触发接口报错

内容的提问来源于stack exchange，提问作者kojo justine