Flutter AWS服务集成插件pip_services4_aws的使用

AWS特定组件用于Dart

此模块是Pip.Services多语言微服务工具包的一部分。

该模块包含支持AWS云平台工作的组件。

模块包含以下包：

• Build - 构建模块组件的工厂
• Clients - 用于与AWS Lambda交互的客户端组件
• Connect - 安装和连接设置组件
• Container - 用于创建AWS Lambda服务器端函数的容器组件
• Count - 使用CloudWatch AWS服务保存数据的计数器（指标）组件
• Log - 将数据保存在CloudWatch AWS服务中的日志组件

快速链接：

• 配置
• aws-lambda-dart-runtime
• aws-client
• API 参考
• 变更日志
• 获取帮助
• 贡献

警告

服务目前尚未完成。开发进度如下：

• CloudWatchCounters 和 CloudWatchLogger 组件已测试并正常工作。
• 创建用于Lambda服务的服务器端函数的组件已测试并工作，但由于在dart2native中使用了dart:mirrors，因此无法构建。要在Linux以外的操作系统上构建，请使用docker和build_lambda.ps1脚本。
• 创建用于Lambda服务的客户端组件尚未完全测试。需要在AWS上进行全面测试。

使用

将以下内容添加到您的pubspec.yaml文件中：

dependencies:
  pip_services4_aws: version

现在可以从命令行安装包：

pub get

开发

对于开发，您需要安装以下前提条件：

• Dart SDK 3
• Visual Studio Code 或您选择的其他IDE
• Docker

安装依赖项：

pub get

运行自动化测试：

pub run test

生成API文档：

./docgen.ps1

在提交更改之前，运行docker化的构建和测试：

./build.ps1
./test.ps1
./clear.ps1

联系方式

Dart版本的Pip.Services由以下人员创建和维护：

• Sergey Seroukhov
• Levichev Dmitry

文档由以下人员编写：

• Levichev Dmitry

示例代码

import 'dart:io';

import 'package:pip_services4_components/pip_services4_components.dart';
import 'package:pip_services4_data/pip_services4_data.dart';

import './Dummy.dart';
import 'DummyCommandableLambdaClient.dart';
import 'DummyCommandableLambdaFunction.dart';

void main() async {
  var awsAccessId = Platform.environment['AWS_ACCESS_ID'];
  var awsAccessKey = Platform.environment['AWS_ACCESS_KEY'];
  var lambdaArn = Platform.environment['LAMBDA_ARN'];
  var config = ConfigParams.fromTuples([
    'logger.descriptor',
    'pip-services:logger:console:default:1.0',
    'service.descriptor',
    'pip-services-dummies:service:default:default:1.0'
  ]);
  var lambdaConfig = ConfigParams.fromTuples([
    'connection.protocol',
    'aws',
    'connection.arn',
    lambdaArn,
    'credential.access_id',
    awsAccessId,
    'credential.access_key',
    awsAccessKey,
    'options.connection_timeout',
    30000
  ]);

  DummyCommandableLambdaFunction lambda;
  DummyCommandableLambdaClient client;

  lambda = DummyCommandableLambdaFunction();
  lambda.configure(config);

  await lambda.open(null);

  client = DummyCommandableLambdaClient();

  client.configure(lambdaConfig);
  await client.open(null);

  var dummy1 = Dummy(id: null, key: 'Key 1', content: 'Content 1');
  var dummy2 = Dummy(id: null, key: 'Key 2', content: 'Content 2');

  // 创建一个dummy
  try {
    var dummy = await client.createDummy(null, dummy1);
    // 处理创建的项目

    dummy1 = dummy!;
  } catch (err) {
    // 错误处理
  }

  // 创建另一个dummy
  try {
    var dummy = await client.createDummy(null, dummy2);
    // 处理第二个创建的项目
    dummy2 = dummy!;
  } catch (err) {
    // 错误处理
  }

  // 获取所有dummies
  try {
    var dummies = await client.getDummies(
        null, FilterParams(), PagingParams(0, 5, false));
    print(dummies);
    // 处理接收到的项目
  } catch (err) {
    // 错误处理
  }

  // 更新dummy
  try {
    dummy1.content = 'Updated Content 1';
    var dummy = await client.updateDummy(null, dummy1);
    // 处理更新后的项目
    dummy1 = dummy!;
  } catch (err) {
    // 错误处理
  }

  // 删除dummy
  try {
    await client.deleteDummy(null, dummy1.id!);
  } catch (err) {
    // 错误处理
  }

  // 尝试获取删除的dummy
  try {
    var dummy = await client.getDummyById(null, dummy1.id!);
    print(dummy);
    // 处理已删除的项目
  } catch (err) {
    // 错误处理
  }
  // 关闭服务和客户端
  await client.close(null);
}