Обработка ошибок в Java Capture и создание события в Alibaba Cloud
Я новичок в Java и нахожусь в процессе обучения. У меня есть интеграция с Alicloud, где я создаю Java-функцию Compute.
Мне нужно подключиться к службе управления ключами (KMS), чтобы получить секрет. Если KMS недоступен или не может подключиться по функциям, мне нужно создать сообщение о событии в теме в MNS. Я хотел знать, как мне справиться с этой ошибкой?
Фрагмент кода ниже.
public class SFTP14 implements StreamRequestHandler, FunctionInitializer {
public void initialize(Context context) throws IOException {
}
public void handleRequest( InputStream inputStream
, OutputStream outputStream
, Context context) throws IOException
{
// Get values from Environment varaible of function
String bucketname = System.getenv("BUCKET_NAME");
String endpoint = System.getenv("ENDPOINT");
String kmssecret = System.getenv("KMSSECRET");
String MNSEndpoint="http://mns.cn-shanghai.aliyuncs.com/";
outputStream.write(new String("Bucket Name:"+bucketname +" \n").getBytes());
outputStream.write(new String("End Point Name:"+endpoint +" \n").getBytes());
// Get credential from Funcion compute service
Credentials creds = context.getExecutionCredentials();
String AccessID= creds.getAccessKeyId();
String AccessKey= creds.getAccessKeySecret();
String SecurityToken =creds.getSecurityToken();
//outputStream.write(new String("Secret AccessID:"+AccessID +" \n").getBytes());
//outputStream.write(new String("Secret AccessKey:"+AccessKey +" \n").getBytes());
//DefaultProfile profile = DefaultProfile.getProfile("cn-shanghai", accessKeyId, accessKeySecret);
DefaultProfile profile = DefaultProfile.getProfile("cn-shanghai", AccessID, AccessKey,SecurityToken);
IAcsClient client = new DefaultAcsClient(profile);
// Get secret data from KMS
GetSecretValueRequest request = new GetSecretValueRequest();
request.setSecretName(kmssecret);
CloudAccount account = new CloudAccount(AccessID,AccessKey,ServiceSettings.getMNSAccountEndpoint(),SecurityToken);
//DefaultMNSClient MNSclient = new DefaultMNSClient(creds.getAccessKeyId(), creds.getAccessKeySecret(),MNSEndpoint) ;
CloudTopic topic = MNSclient.getTopicRef("myTopic");
try
{
GetSecretValueResponse response = client.getAcsResponse(request);
**if (response== null)
{
throw new Exception("Cant connect to KMS");
}**
JSONObject obj= new JSONObject(response);
String SecretData = obj.getString("secretData");
JSONObject SecretData1= new JSONObject(SecretData);
String user = SecretData1.getString("username");
String password = SecretData1.getString("password");
String host = SecretData1.getString("host");
String port1 = SecretData1.getString("port");
int port=Integer.parseInt(port1);
String remotePath = SecretData1.getString("remotepath");
// Print values got from KMS Secret
outputStream.write(new String("Secret UserName:"+user +" \n").getBytes());
outputStream.write(new String("Secret Password:"+password +" \n").getBytes());
outputStream.write(new String("Secret Host:"+host +" \n").getBytes());
outputStream.write(new String("Secret Port:"+port1 +" \n").getBytes());
outputStream.write(new String("Secret remotePath:"+remotePath +" \n\n").getBytes());
//TopicMessage msg1 = new TopicMessage(); // You can specify whether to perform Base64 encoding on topic messages.
TopicMessage msg = new RawTopicMessage();
//TopicMessage msg1 = new RawTopicMessage();
outputStream.write(new String("hello world to AliCloud\n").getBytes());
// Create an OSSClient instance.
outputStream.write(new String("Start to create OSS client\n").getBytes());
// OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
OSS ossClient = new OSSClientBuilder().build(endpoint, creds.getAccessKeyId(), creds.getAccessKeySecret() ,creds.getSecurityToken());
outputStream.write(new String("OSS client created.\n").getBytes());
JSch jsch = new JSch();
outputStream.write(new String("Jsch instanciated\n").getBytes());
Session session = jsch.getSession(user, host, port);
session.setPassword(password);
// rational
session.setConfig("StrictHostKeyChecking", "no");
outputStream.write(new String("Jsch session created, Establishing Connection...\n").getBytes());
session.connect();
outputStream.write(new String("...Connection established\n").getBytes());
outputStream.write(new String("establish sftp channel...\n").getBytes());
ChannelSftp sftpChannel = (ChannelSftp) session.openChannel("sftp");
sftpChannel.connect();
outputStream.write(new String("...sftp channel established\n").getBytes());
sftpChannel.cd(remotePath);
outputStream.write(new String("...changed directory\n").getBytes());
Vector lsVector = sftpChannel.ls("*");
outputStream.write(new String("ls vector created\n").getBytes());
Enumeration en = lsVector.elements();
outputStream.write(new String("ls elements are:\n").getBytes());
String filename;
ChannelSftp.LsEntry LsEntry;
if(lsVector.isEmpty()==true)
{
outputStream.write(new String("Publish Message \n").getBytes());
//msg.setMessageBody("hello world!") ;
msg.setMessageBody(("hello bytes with tag! ").getBytes());
msg = topic.publishMessage(msg);
throw new Exception("No File Found");
}
else
{
while(en.hasMoreElements())
{
LsEntry = (ChannelSftp.LsEntry)en.nextElement();
filename = LsEntry.getFilename();
// else {
outputStream.write(new String(filename+" \n").getBytes());
InputStream fileIS = sftpChannel.get(filename);
// filename with extension ?
ossClient.putObject(bucketname, filename, fileIS);
// remove remote file from FTP server
sftpChannel.rm(filename);
// }
}
}
// Shut down the OSSClient instance.
ossClient.shutdown();
sftpChannel.disconnect();
outputStream.write(new String("sftp channel disconnected\n").getBytes());
session.disconnect();
outputStream.write(new String("disconnected from session\n").getBytes());
}
catch(Exception e)
{
outputStream.write(new String("Error Message:"+e.getMessage() +" \n\n").getBytes());
}
}
}
В основном я хочу зафиксировать ошибку, возникающую во время выполнения, и выполнить некоторые действия на ее основе.
Например:
if exception=Forbidden.NoPermission
then
Publish a message in topic with the error message occurs.
Описание ошибок для Alibaba Cloud KMS подробно описано здесь.
https://error-center.alibabacloud.com/status/product/Kms?spm=a2c69.11428812.home.32.1f39bb9amMIo4u
Может ли кто-нибудь помочь мне отловить ошибку и поднять сообщение в MNS?
Спасибо, Amdone
1 ответ
Я предполагаю, что вы вызовете функцию асинхронно, а не синхронизируете ее. Если это так, существует гораздо более простое решение, при котором вам не нужно писать код для уведомления MNS.
Alibaba Cloud Function Compute поддерживает функцию назначения
Вот как выглядит процесс:
- Вы настраиваете конфигурацию асинхронного вызова для функции - когда функция возвращается ненормально, уведомляет тему MNS.
- В функции вы вызываете KMS. В случае успеха вы выполняете свою бизнес-логику; В противном случае просто выбросите исключение.
Это оно!