Flutter应用商店集成插件azstore的使用

简介

azstore 是一个用于访问Azure存储选项的Flutter插件，通过REST APIs提供对Azure Blob、Table和Queue的支持。本文将详细介绍如何在Flutter项目中使用该插件。

安装

首先，在pubspec.yaml文件中添加依赖：

dependencies:
  azstore: ^latest_version

然后运行 flutter pub get 来安装插件。

导入

在需要使用的地方导入插件：

import 'package:azstore/azstore.dart';

使用示例

获取连接字符串

在Azure门户中创建存储账户后，可以获取连接字符串。具体步骤如下：

1. 登录Azure门户并导航到存储账户。
2. 在左侧菜单中选择“访问密钥”，然后点击“显示密钥”以查看连接字符串。

Azure Blob Functions

上传图片

Future<void> testUploadImage() async {
  File testFile = File('C:/Users/HP/Pictures/fdblack.png');
  Uint8List bytes = await testFile.readAsBytes();
  var storage = AzureStorage.parse('your connection string');
  try {
    await storage.putBlob('/azpics/fdblack.png',
      bodyBytes: bytes,
      contentType: 'image/png',
    );
    print('Image uploaded successfully');
  } catch (e) {
    print('Exception: $e');
  }
}

删除Blob

Future<void> testDeleteBlob() async {
  var storage = AzureStorage.parse('your connection string');
  try {
    await storage.deleteBlob('/azpics/fdblack.png');
    print('Blob deleted successfully');
  } catch (e) {
    print('Exception: $e');
  }
}

Table Storage Functions

插入表行

Future<void> testUpload2Table() async {
  var storage = AzureStorage.parse('your connection string');
  try {
    var myPartitionKey = 'partition_key';
    var myRowKey = '237';
    Map<String, dynamic> rowMap = {
      "Address": "Santa Clara",
      "Age": 23,
      "AmountDue": 200.23,
      "CustomerCode@odata.type": "Edm.Guid",
      "CustomerCode": "c9da6455-213d-42c9-9a79-3e9149a57833",
      "CustomerSince@odata.type": "Edm.DateTime",
      "CustomerSince": "2008-07-10T00:00:00",
      "IsActive": false,
      "NumberOfOrders@odata.type": "Edm.Int64",
      "NumberOfOrders": "255",
      "PartitionKey": "$myPartitionKey",
      "RowKey": "$myRowKey"
    };
    await storage.upsertTableRow(
        tableName: 'profiles',
        rowKey: myRowKey,
        partitionKey: myPartitionKey,
        bodyMap: rowMap);
    print('Row inserted successfully');
  } catch (e) {
    print('Tables upsert exception: $e');
  }
}

查询表行

Future<void> testGetTableRow() async {
  var storage = AzureStorage.parse('your connection string');
  try {
    var myPartitionKey = 'partition_key';
    var myRowKey = 'unique_row_id';
    String result = await storage.getTableRow(
        tableName: 'profiles',
        partitionKey: myPartitionKey,
        rowKey: myRowKey,
        fields: ['Address', 'CustomerSince']);
    print('Result: $result');
  } catch (e) {
    print('Tables get exception: $e');
  }
}

Azure Queue Functions

创建队列

Future<void> testCreateQ() async {
  try {
    var storage = AzureStorage.parse('your connection string');
    await storage.createQueue('myqueue');
    print('Queue created successfully');
  } catch (e) {
    print('Create queue error: $e');
  }
}

插入消息

Future<void> testPutMessage() async {
  var storage = AzureStorage.parse('your connection string');
  try {
    await storage.putQMessage(qName: 'ttable', message: 'testing queue updates');
    print('Message inserted successfully');
  } catch (e) {
    print('Get data error: ${e.statusCode} ${e.message}');
  }
}

完整Demo

以下是一个完整的Flutter应用示例，展示了如何使用azstore插件进行各种操作：

import 'dart:io';
import 'dart:typed_data';
import 'package:azstore/azstore.dart';
import 'package:flutter/material.dart';

void main() {
  runApp(MyApp());
}

class MyApp extends StatelessWidget {
  [@override](/user/override)
  Widget build(BuildContext context) {
    return MaterialApp(
      title: 'Azstore Demo App',
      theme: ThemeData(
        primarySwatch: Colors.blue,
      ),
      home: MyHomePage(title: 'Azstore Demo'),
    );
  }
}

class MyHomePage extends StatefulWidget {
  MyHomePage({Key key, this.title}) : super(key: key);

  final String title;

  [@override](/user/override)
  _MyHomePageState createState() => _MyHomePageState();
}

class _MyHomePageState extends State<MyHomePage> {
  final _connectionString = 'your_connection_string_here';
  bool _progress = false;

  Future<void> uploadImage() async {
    try {
      File testFile = File('path_to_your_image_file');
      Uint8List bytes = await testFile.readAsBytes();
      var storage = AzureStorage.parse(_connectionString);
      await storage.putBlob('/azpics/test.png',
          bodyBytes: bytes,
          contentType: 'image/png');
      print('Image uploaded successfully');
    } catch (e) {
      print('Exception: $e');
    }
  }

  [@override](/user/override)
  Widget build(BuildContext context) {
    return Scaffold(
      appBar: AppBar(
        title: Text(widget.title),
      ),
      body: Center(
        child: Column(
          mainAxisAlignment: MainAxisAlignment.center,
          children: <Widget>[
            ElevatedButton(
              onPressed: () async {
                setState(() {
                  _progress = true;
                });
                await uploadImage();
                setState(() {
                  _progress = false;
                });
              },
              child: Text('Upload Image'),
            ),
          ],
        ),
      ),
    );
  }
}