Flutter集成Google Cloud服务插件google_cloud的使用

简介

google_cloud 是一个用于在 Google Cloud Platform (GCP) 上正确运行 Dart 代码的工具包。该项目由社区支持，没有官方的支持级别，代码不受任何 SLA 或弃用政策的保护。

功能包括：

• 访问配置的监听端口。
• 访问配置的 Google Cloud 项目 ID。
• 支持 结构化日志记录。

未来可能会添加更多功能。

反馈和问题

如果您有任何想法或遇到问题，请在 GitHub 讨论区 开始讨论，或在 GitHub 问题跟踪器 中提交问题。

示例代码

以下是一个使用 google_cloud 插件访问 Google Cloud Firestore 的示例代码。该示例展示了如何创建一个简单的 HTTP 服务器，通过 Firestore 增加一个计数器。

// Copyright (c) 2021, the Dart project authors. Please see the AUTHORS file
// for details. All rights reserved. Use of this source code is governed by a
// BSD-style license that can be found in the LICENSE file.

import 'dart:convert';
import 'package:google_cloud/google_cloud.dart';
import 'package:googleapis/firestore/v1.dart';
import 'package:googleapis_auth/auth_io.dart';
import 'package:shelf/shelf.dart';
import 'package:shelf/shelf_io.dart' as shelf_io;

Future<void> main() async {
  final server = await _Server.create();

  try {
    await serveHandler(server.handler);
  } finally {
    server.close();
  }
}

class _Server {
  _Server._({
    required this.projectId,
    required this.client,
    required this.hosted,
  });

  static Future<_Server> create() async {
    String? projectId;
    bool hosted;

    try {
      projectId = await projectIdFromMetadataServer();
      hosted = true;
    } on BadConfigurationException {
      projectId = projectIdFromEnvironment();
      hosted = false;
    }

    if (projectId == null) {
      throw BadConfigurationException(
        '''
Could not contact GCP metadata server or find the project-id in one of these
environment variables:
  ${gcpProjectIdEnvironmentVariables.join('\n  ')}''',
      );
    }

    print('Current GCP project id: $projectId');

    final authClient = await clientViaApplicationDefaultCredentials(
      scopes: [FirestoreApi.datastoreScope],
    );

    return _Server._(projectId: projectId, client: authClient, hosted: hosted);
  }

  final String projectId;
  final AutoRefreshingAuthClient client;
  final bool hosted;

  late final FirestoreApi api = FirestoreApi(client);
  late final handler =
      createLoggingMiddleware(projectId: hosted ? projectId : null)
          .addMiddleware(_onlyGetRootMiddleware)
          .addHandler(_incrementHandler);

  Future<Response> _incrementHandler(Request request) async {
    final result = await api.projects.databases.documents.commit(
      _incrementRequest(projectId),
      'projects/$projectId/databases/(default)',
    );

    return Response.ok(
      JsonUtf8Encoder(' ').convert(result),
      headers: {'content-type': 'application/json'},
    );
  }

  void close() {
    client.close();
  }
}

/// 对于 `GET` 请求对象到 [handler]，否则返回 404。
Handler _onlyGetRootMiddleware(Handler handler) => (Request request) async {
      if (request.method == 'GET' && request.url.pathSegments.isEmpty) {
        return await handler(request);
      }

      throw BadRequestException(404, 'Not found');
    };

CommitRequest _incrementRequest(String projectId) => CommitRequest(
      writes: [
        Write(
          transform: DocumentTransform(
            document:
                'projects/$projectId/databases/(default)/documents/settings/count',
            fieldTransforms: [
              FieldTransform(
                fieldPath: 'count',
                increment: Value(integerValue: '1'),
              ),
            ],
          ),
        ),
      ],
    );

Future<void> serveHandler(Handler handler) async {
  final server = await shelf_io.serve(handler, InternetAddress.anyIPv4, 8080);
  print('Serving at http://${server.address.host}:${server.port}');
}

说明

1. 项目 ID 获取：_Server 类中的 create 方法尝试从 GCP 元数据服务器获取项目 ID，如果失败则从环境变量中获取。
2. 身份验证：使用 clientViaApplicationDefaultCredentials 获取自动刷新的身份验证客户端。
3. HTTP 服务器：使用 shelf 和 shelf_io 创建一个简单的 HTTP 服务器，处理 GET 请求并增加 Firestore 中的计数器。
4. 日志记录：使用 createLoggingMiddleware 添加结构化日志记录。

运行示例

1. 确保你已经安装了 Dart 和 Flutter。

2. 配置 GCP 项目并启用 Firestore API。

3. 设置环境变量 GOOGLE_APPLICATION_CREDENTIALS 指向你的服务账户密钥文件。

4. 运行示例代码：

   dart run
   

5. 访问 http://localhost:8080 查看结果。

希望这个示例能帮助你更好地理解和使用 google_cloud 插件。如果有任何问题或建议，请随时提出。