狠狠狠的在啪线香蕉,在线观看中文字幕一二三区,制服中文字幕在线一区

當ECS實例或部署在ECS實例上的應用需要訪問其他云資源時，必須配置訪問憑證，阿里云服務會通過訪問憑證驗證您的身份信息和訪問權限。實例RAM角色允許您將一個角色關聯到ECS實例，實現在實例內部自動獲取并刷新臨時訪問憑證，無需直接暴露AccessKey，減少密鑰泄露的風險。同時，也可借助RAM角色精細化控制資源訪問權限，避免權限過度分配。本文介紹在ECS中無需AccessKey直接訪問日志服務SDK的操作步驟。

說明

實例RAM角色是一種可信實體為阿里云服務的RAM角色，即允許云服務扮演的角色，用于解決跨服務訪問問題。關于RAM角色的詳細說明，請參見什么是RAM角色。
阿里云訪問密鑰（AccessKey）是調用API訪問云資源的安全口令，您可以使用AccessKey簽名API請求內容以通過服務端的安全驗證。關于AccessKey的詳細說明，請參見訪問密鑰。
日志服務自定義權限策略信息請參見RAM自定義授權示例。

使用限制

目前僅Java SDK、Go SDK支持ECS無AccessKey訪問日志服務SDK。
ECS實例的網絡類型必須是專有網絡VPC。
一臺ECS實例只能授予一個實例RAM角色。

步驟一：創建ECS實例RAM角色并授予給ECS

通過控制臺創建和授予

登錄RAM控制臺，創建實例RAM角色。
創建可信實體為阿里云服務的RAM角色。
選擇身份管理 > 角色，單擊創建角色，按照界面提示完成角色創建。注意以下參數（其他參數按需填寫，可參見創建普通服務角色）：
- 可信實體類型：選擇阿里云服務。
- 角色類型：選擇普通服務角色。
- 受信服務：選擇云服務器。
為已創建的實例RAM角色授權。
將系統策略或已創建的自定義權限策略授權給RAM用戶，使其擁有相關的資源訪問或操作權限。例如，給角色賦予日志服務的只讀權限（AliyunLogReadOnlyAccess）。
說明
支持添加系統策略或自定義策略。若系統策略不滿足您的需求，可新建自定義策略。具體操作，請參見創建自定義權限策略。
授予實例RAM角色給ECS實例。
1. 登錄ECS管理控制臺。
2. 在左側導航欄，選擇實例與鏡像 > 實例。
3. 在頁面左側頂部，選擇目標資源所在的資源組和地域。
4. 找到要操作的ECS實例，選擇 > 實例設置 > 授予/收回RAM角色。
5. 在對話框中，選擇創建好的實例RAM角色，單擊確定。

通過API創建和授予

創建并配置實例RAM角色

調用CreateRole接口創建實例RAM角色。

按如下策略設置參數AssumeRolePolicyDocument：

{
     "Statement": [
     {
         "Action": "sts:AssumeRole",
         "Effect": "Allow",
         "Principal": {
         "Service": [
         "ecs.aliyuncs.com"
         ]
         }
     }
     ],
     "Version": "1"
 }

（可選）調用CreatePolicy接口新建權限策略。

如果您已有可用權限策略，可跳過該步驟。

PolicyDocument（權限策略）需按如下設置：

{
     "Statement": [
         {
         "Action": [
             "oss:Get*",
             "oss:List*"
         ],
         "Effect": "Allow",
         "Resource": "*"
         }
     ],
     "Version": "1"
 }

調用AttachPolicyToRole接口為實例RAM角色授權。
調用AttachInstanceRamRole接口將RAM角色授予ECS實例。

步驟二：訪問日志服務SDK

Java

Java SDK

在Maven工程中使用日志服務Java SDK，只需在pom.xml中加入相應依賴。更多信息，請參見Java SDK。
重要
Java SDK最低版本號為0.6.110。
```
<dependency>
    <groupId>com.aliyun.openservices</groupId>
    <artifactId>aliyun-log</artifactId>
    <version>0.6.110</version>
</dependency>
```

Client類入參取消AccessKey，傳入步驟一創建的實例RAM角色名稱。

import com.aliyun.openservices.log.exception.LogException;
import com.aliyun.openservices.log.response.GetProjectResponse;

public class Main {
  public static void main(String[] args) throws LogException {
    // 這里將RoleName替換成上面創建的 ram 角色名
    Client client = new Client("cn-hangzhou.log.aliyuncs.com", "RoleName");
    GetProjectResponse resp = client.GetProject("your-project");
    System.out.println(resp.GetProjectDescription());
  }
}

Java Producer

在Maven工程中使用日志服務Aliyun Log Java Producer，只需在pom.xml中加入相應依賴。更多信息，請參見Aliyun Log Java Producer。
重要
Java Producer最低版本號為0.3.22。
```
<dependency>
    <groupId>com.aliyun.openservices</groupId>
    <artifactId>aliyun-log-producer</artifactId>
    <version>0.3.22</version>
</dependency>
```

配置日志項目中ProjectConfig入參取消AccessKey，傳入步驟一創建的實例RAM角色名稱。

import com.aliyun.openservices.aliyun.log.producer.*;
import com.aliyun.openservices.aliyun.log.producer.errors.ProducerException;
import com.aliyun.openservices.log.common.LogItem;
import com.aliyun.openservices.log.common.auth.CredentialsProvider;
import com.aliyun.openservices.log.common.auth.ECSRoleCredentialsProvider;

public class ExampleUsage {

    public static void main(String[] args) throws ProducerException, InterruptedException {
        String endpoint = "cn-hangzhou.log.aliyuncs.com";
        String project = "your-project";
        String logStore = "your-logstore";
        // 配置ProducerConfig
        Config producerConfig = new ProducerConfig();
        // 創建Producer
        Producer producer = new LogProducer(new ProducerConfig());
        // 這里將 your-ecs-ram-role-name 替換成上面創建的 ram 角色名
        CredentialsProvider provider = new ECSRoleCredentialsProvider("your-ecs-ram-role-name");
        // 配置日志項目
        ProjectConfig projectConfig = new ProjectConfig(project, endpoint, provider, null);
        producer.putProjectConfig(projectConfig);

        // send logs
        producer.send(project, logStore, buildLogItem());
        producer.send(project, logStore, null, null, buildLogItem());
        producer.send(project, logStore, "", "", buildLogItem());
        producer.close();
    }

    public static LogItem buildLogItem() {
        LogItem logItem = new LogItem();
        logItem.PushBack("k1", "v1");
        logItem.PushBack("k2", "v2");
        return logItem;
    }
}

Java Consumer

在Maven工程中使用日志服務Aliyun LOG Java Consumer，只需在pom.xml中加入相應依賴。更多信息，請參見通過消費組消費數據。
重要
Java Consumer最低版本號為0.6.47。
```
<dependency>
  <groupId>com.aliyun.openservices</groupId>
  <artifactId>loghub-client-lib</artifactId>
  <version>0.6.47</version>
</dependency>
```

創建消費者LogHubConfig入參取消AccessKey，傳入步驟一創建的實例RAM角色名稱。

import com.aliyun.openservices.log.common.auth.ECSRoleCredentialsProvider;
import com.aliyun.openservices.log.common.auth.CredentialsProvider;
import com.aliyun.openservices.loghub.client.ClientWorker;
import com.aliyun.openservices.loghub.client.config.LogHubConfig;
import com.aliyun.openservices.loghub.client.exceptions.LogHubClientWorkerException;

public class Main {
    private static String Endpoint = "cn-hangzhou.log.aliyuncs.com";
    private static String Project = "your-project";
    private static String Logstore = "your-logstore";
    private static String ConsumerGroup = "consumerGroupX";

    public static void main(String[] args) throws LogHubClientWorkerException, InterruptedException {
        // 這里將 your-ecs-ram-role-name 替換成上面創建的 ram 角色名
        CredentialsProvider provider = new ECSRoleCredentialsProvider("your-ecs-ram-role-name");

        LogHubConfig config = new LogHubConfig(ConsumerGroup, "consumer_1", Endpoint, Project, Logstore, provider,
                LogHubConfig.ConsumePosition.BEGIN_CURSOR);
        config.setMaxFetchLogGroupSize(1000);

        ClientWorker worker = new ClientWorker(new SampleLogHubProcessorFactory(), config);
        Thread thread = new Thread(worker);
        thread.start();
        Thread.sleep(60 * 60 * 1000);
        worker.shutdown();
        Thread.sleep(30 * 1000);
    }
}

Go

重要

無AccessKey訪問日志服務Go SDK，Go SDK最低版本號為 0.1.83。升級Go SDK，請參見安裝或升級SDK。

Go SDK

provider入參傳入步驟一創建的實例RAM角色名稱。

package main

import (
	"fmt"

	sls "github.com/aliyun/aliyun-log-go-sdk"
)

func main() {
        // 日志服務的服務入口。此處以杭州為例，其它地域請根據實際情況填寫。
	Endpoint := "cn-chengdu.log.aliyuncs.com"
	// 這里將 your-ecs-ram-role-name 替換成上面創建的 ram 角色名
	provider := sls.NewEcsRamRoleCredentialsProvider("your-ecs-ram-role-name")
	// 創建日志服務Client。
	client := sls.CreateNormalInterfaceV2(Endpoint, provider)
	resp, err := client.GetProject("your-project")
	if err != nil {
		panic(err)
	}
	fmt.Println(resp.Description)
}

Go Producer

配置ProducerConfig中provider入參傳入步驟一創建的實例RAM角色名稱。

package main

import (
	"fmt"
	"os"
	"os/signal"
	"sync"
	"time"

	sls "github.com/aliyun/aliyun-log-go-sdk"
	"github.com/aliyun/aliyun-log-go-sdk/producer"
	"github.com/gogo/protobuf/proto"
)

func main() {
	producerConfig := producer.GetDefaultProducerConfig()
	producerConfig.Endpoint = "cn-hangzhou.log-aliyuncs.com"
    // 這里將 your-ecs-ram-role-name 替換成上面創建的 ram 角色名
	provider := sls.NewEcsRamRoleCredentialsProvider("your-ecs-ram-role-name")
	producerConfig.CredentialsProvider = provider
	producerInstance := producer.InitProducer(producerConfig)
	ch := make(chan os.Signal)
	signal.Notify(ch, os.Kill, os.Interrupt)
	producerInstance.Start()
    
	var m sync.WaitGroup
	for i := 0; i < 10; i++ {
		m.Add(1)
		go func() {
			defer m.Done()
			for i := 0; i < 1000; i++ {
				log := producer.GenerateLog(uint32(time.Now().Unix()), map[string]string{"content": "test", "content2": fmt.Sprintf("%v", i)})
				err := producerInstance.SendLog("log-project", "log-store", "topic", "127.0.0.1", log)
				if err != nil {
					fmt.Println(err)
				}
			}
		}()
	}
	m.Wait()
	fmt.Println("Send completion")
	if _, ok := <-ch; ok {
		fmt.Println("Get the shutdown signal and start to shut down")
		producerInstance.Close(60000)
	}
}

Go Consumer

CredentialsProvider入參傳入步驟一創建的實例RAM角色名稱。

package main

import (
	"fmt"
	"os"
	"os/signal"
	"syscall"

	sls "github.com/aliyun/aliyun-log-go-sdk"
	consumerLibrary "github.com/aliyun/aliyun-log-go-sdk/consumer"
	"github.com/go-kit/kit/log/level"
)

func main() {
	option := consumerLibrary.LogHubConfig{
		Endpoint: "cn-hangzhou.log-aliyuncs.com",
		// 這里將 your-ecs-ram-role-name 替換成上面創建的 ram 角色名
		CredentialsProvider: sls.NewEcsRamRoleCredentialsProvider("your-ecs-ram-role-name"),
		Project:             "your-project",
		Logstore:            "your-logstore",
		ConsumerGroupName:   "your-consumer-group",
		ConsumerName:        "your-consumer-group-consumer-1",
		CursorPosition:      consumerLibrary.END_CURSOR,
	}

	consumerWorker := consumerLibrary.InitConsumerWorkerWithCheckpointTracker(option, process)
	ch := make(chan os.Signal, 1)
	signal.Notify(ch, syscall.SIGINT, syscall.SIGTERM)
	consumerWorker.Start()
	if _, ok := <-ch; ok {
		level.Info(consumerWorker.Logger).Log("msg", "get stop signal, start to stop consumer worker", "consumer worker name", option.ConsumerName)
		consumerWorker.StopAndWait()
	}
}

// 數據消費處理邏輯
func process(shardId int, logGroupList *sls.LogGroupList, checkpointTracker consumerLibrary.CheckPointTracker) (string, error) {
	fmt.Println(shardId, logGroupList)
	checkpointTracker.SaveCheckPoint(false)
	return "", nil
}

日本熟妇hd丰满老熟妇,中文字幕一区二区三区在线不卡 ,亚洲成片在线观看,免费女同在线一区二区

通過ECS無需AccessKey訪問日志服務SDK