Я написал этот код, но он не очень практичен.Я все еще новичок в этой области кодирования.В основном я храню изображение в контейнере BLOB-объектов, и я сохраняю URL в таблице.Я делаю то же самое для текстового файла.Поэтому я хотел бы использовать внедрение зависимостей для Azure, чтобы сделать мой код более практичным.
Вот мой Logo Controller.
[Route("api/manage/logo")]
[ApiController]
public class ManageLogoController : ControllerBase
{
[HttpPost("{version}")]
public async Task<IActionResult> Post(IFormFile image, float version)
{
if (image.Length >= 1048576)
{
return BadRequest("Uploaded image may not exceed 1Mb, please upload a smaller image.");
}
var allowedExtensions = new[] {
".png", ".jpg", "jpeg" };
string fileExt = Path.GetExtension(image.FileName);
if (allowedExtensions.Contains(fileExt))
{
try
{
await LogoStorage.UploadFileToBlobStorage(version, image.FileName);
return Ok(new
{
lenght = image.Length,
name = image.FileName
});
}
catch (Exception ex)
{
return BadRequest();
}
}
TnC Controller
[Route("api/manage/tnc")]
[ApiController]
public class ManageTermCondController : ControllerBase
{
[HttpPost("{version}")]
public async Task<IActionResult> Post(IFormFile doc, float version)
{
var allowedExtension = ".txt";
string fileExt = Path.GetExtension(doc.FileName);
if (allowedExtension.Contains(fileExt))
{
try
{
await TncStorage.UploadDocToBlobStorage(version, doc.FileName);
return Ok(new
{
lenght = doc.Length,
name = doc.FileName
});
}
catch (Exception ex)
{
return BadRequest();
}
}
else
{
return BadRequest("Only .txt files are allowed!");
}
}
[HttpGet]
public string Geti(float version)
{
var x = TncStorage.GetURL(version);
if (x == null)
{
return "There's no such record";
}
else return TncStorage.GetURL(version);
}
}
Я создал новую библиотеку классов с именем .Service для следующей части.
public class VersionURL : TableEntity
{
public VersionURL(string type, string version)
{
PartitionKey = type;
RowKey = version;
}
public VersionURL() { }
public string URL { get; set; }
public string ETag { get; set; }
}
Первый класс.
public static async Task UploadFileToBlobStorage(float version, string filename)
{
CloudStorageAccount storageAccount = null;
CloudBlobContainer cloudBlobContainer = null;
string storageConnectionString = "";
if (CloudStorageAccount.TryParse(storageConnectionString, out storageAccount))
{
try
{
CloudBlobClient cloudBlobClient = storageAccount.CreateCloudBlobClient();
cloudBlobContainer = cloudBlobClient.GetContainerReference("logodata");
await cloudBlobContainer.CreateIfNotExistsAsync();
BlobContainerPermissions permissions = new BlobContainerPermissions
{
PublicAccess = BlobContainerPublicAccessType.Blob
};
await cloudBlobContainer.SetPermissionsAsync(permissions);
var blobUrl = "";
string file = Guid.NewGuid().ToString() + Path.GetExtension(filename);
CloudBlockBlob cloudBlockBlob = cloudBlobContainer.GetBlockBlobReference(file);
try
{
await cloudBlockBlob.UploadFromFileAsync(filename);
}
catch (Exception ex)
{
}
blobUrl = cloudBlockBlob.Uri.AbsoluteUri;
CloudTableClient tableClient = storageAccount.CreateCloudTableClient();
CloudTable table = tableClient.GetTableReference("CommonURL");
await table.CreateIfNotExistsAsync();
var v = "v" + version;
VersionURL content = new VersionURL("Logo", v);
content.ETag = "*";
content.URL = blobUrl;
var query = new TableQuery<VersionURL>().Where(TableQuery.GenerateFilterCondition("RowKey", QueryComparisons.Equal, v));
TableContinuationToken continuationToken = null;
do
{
var result = await table.ExecuteQuerySegmentedAsync(query, continuationToken);
continuationToken = result.ContinuationToken;
if (result.Count() != 0)
{
foreach (VersionURL entity in result)
{
if (entity.RowKey == v)
{
try
{
TableOperation updateOperation = TableOperation.Merge(content);
await table.ExecuteAsync(updateOperation);
}
catch (Exception ex)
{
}
}
}
}
else
{
TableOperation insertOperation = TableOperation.Insert(content);
await table.ExecuteAsync(insertOperation);
}
} while (continuationToken != null);
}
catch (StorageException ex)
{
Console.WriteLine("Error returned from the service: {0}", ex.Message);
}
finally
{
}
}
else
{
Console.WriteLine(
"A connection string has not been defined in the system environment variables. " +
"Add a environment variable named 'storageconnectionstring' with your storage " +
"connection string as a value.");
}
}
}
Второй класс.
public class TncStorage
{
public static async Task UploadDocToBlobStorage(float version, string filename)
{
CloudStorageAccount storageAccount = null;
CloudBlobContainer cloudBlobContainer = null;
string storageConnectionString = "";
if (CloudStorageAccount.TryParse(storageConnectionString, out storageAccount))
{
try
{
CloudBlobClient cloudBlobClient = storageAccount.CreateCloudBlobClient();
cloudBlobContainer = cloudBlobClient.GetContainerReference("tncdata");
await cloudBlobContainer.CreateIfNotExistsAsync();
BlobContainerPermissions permissions = new BlobContainerPermissions
{
PublicAccess = BlobContainerPublicAccessType.Blob
};
await cloudBlobContainer.SetPermissionsAsync(permissions);
var blobUrl = "";
string file = Guid.NewGuid().ToString() + Path.GetExtension(filename);
CloudBlockBlob cloudBlockBlob = cloudBlobContainer.GetBlockBlobReference(file);
try
{
await cloudBlockBlob.UploadFromFileAsync(filename);
}
catch (Exception ex)
{
}
blobUrl = cloudBlockBlob.Uri.AbsoluteUri;
CloudTableClient tableClient = storageAccount.CreateCloudTableClient();
CloudTable table = tableClient.GetTableReference("CommonURL");
await table.CreateIfNotExistsAsync();
var v = "v" + version;
VersionURL content = new VersionURL("TnC", v);
content.ETag = "*";
content.URL = blobUrl;
var query = new TableQuery<VersionURL>().Where(TableQuery.GenerateFilterCondition("RowKey", QueryComparisons.Equal, v));
TableContinuationToken continuationToken = null;
do
{
var result = await table.ExecuteQuerySegmentedAsync(query, continuationToken);
continuationToken = result.ContinuationToken;
if (result.Count() != 0)
{
foreach (VersionURL entity in result)
{
if (entity.RowKey == v)
{
try
{
var dec = version + .1;
content.RowKey = "v" + dec;
TableOperation updateOperation = TableOperation.Insert(content);
await table.ExecuteAsync(updateOperation);
}
catch (Exception ex)
{
}
}
}
}
else
{
TableOperation insertOperation = TableOperation.Insert(content);
await table.ExecuteAsync(insertOperation);
}
} while (continuationToken != null);
}
catch (StorageException ex)
{
Console.WriteLine("Error returned from the service: {0}", ex.Message);
}
finally
{
}
}
else
{
Console.WriteLine(
"A connection string has not been defined in the system environment variables. " +
"Add a environment variable named 'storageconnectionstring' with your storage " +
"connection string as a value.");
}
}
public static string GetURL(float version)
{
CloudStorageAccount storageAccount = null;
string storageConnectionString = "";
storageAccount = CloudStorageAccount.Parse(storageConnectionString);
CloudTableClient tableClient = storageAccount.CreateCloudTableClient();
CloudTable table = tableClient.GetTableReference("CommonURL");
var v = "v" + version;
var tableQuery = new TableQuery<VersionURL>();
tableQuery = new TableQuery<VersionURL>().Where(TableQuery.GenerateFilterCondition("RowKey", QueryComparisons.Equal, v));
var entities = table.ExecuteQuerySegmentedAsync(tableQuery, null);
var results = entities.Result;
var s = "";
foreach (var file in results.Where(x => x.RowKey == v))
{
//if (file.RowKey == v)
//{
return s = file.URL;
//}
//else
// return null;
}
return null;
}
Можно ли сделать первый и второй класс более простым?