Répertorier les fragments

Un flux de données peut comporter une ou plusieurs partitions. La méthode recommandée pour répertorier ou récupérer les fragments d'un flux de données consiste à utiliser l'ListShardsAPI. L'exemple suivant montre comment vous pouvez obtenir une liste des partitions d'un flux de données. Pour une description complète de l'opération principale utilisée dans cet exemple et de tous les paramètres que vous pouvez définir pour l'opération, consultez ListShards.

import software.amazon.awssdk.services.kinesis.KinesisAsyncClient;
import software.amazon.awssdk.services.kinesis.model.ListShardsRequest;
import software.amazon.awssdk.services.kinesis.model.ListShardsResponse;

import java.util.concurrent.TimeUnit;

public class ShardSample {

    public static void main(String[] args) {

        KinesisAsyncClient client = KinesisAsyncClient.builder().build();

        ListShardsRequest request = ListShardsRequest
                .builder().streamName("myFirstStream")
                .build();

        try {
            ListShardsResponse response = client.listShards(request).get(5000, TimeUnit.MILLISECONDS);
            System.out.println(response.toString());
        } catch (Exception e) {
            System.out.println(e.getMessage());
        }
    }
}

Pour exécuter l'exemple de code précédent, vous pouvez utiliser un fichier POM comme celui qui suit.

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>kinesis.data.streams.samples</groupId>
    <artifactId>shards</artifactId>
    <version>1.0-SNAPSHOT</version>
    <build>
        <plugins>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
                <configuration>
                    <source>8</source>
                    <target>8</target>
                </configuration>
            </plugin>
        </plugins>
    </build>
    <dependencies>
        <dependency>
            <groupId>software.amazon.awssdk</groupId>
            <artifactId>kinesis</artifactId>
            <version>2.0.0</version>
        </dependency>
    </dependencies>
</project>

Avec l'ListShardsAPI, vous pouvez utiliser le ShardFilterparamètre pour filtrer la réponse de l'API. Vous ne pouvez spécifier qu'un seul filtre à la fois.

Si vous utilisez le ShardFilter paramètre lors de l'appel de l' ListShardsAPI, Type il s'agit de la propriété requise qui doit être spécifiée. Si vous spécifiez les types AT_TRIM_HORIZON, FROM_TRIM_HORIZON ou AT_LATEST, vous n'avez pas besoin d'indiquer le ShardId ou les propriétés optionnelles Timestamp.

Si vous spécifiez le type AFTER_SHARD_ID, vous devez également indiquer la valeur de la propriété optionnelle ShardId. La fonctionnalité de la ShardId propriété est identique à celle du ExclusiveStartShardId paramètre de l' ListShards API. Lorsque la propriété ShardId est indiquée, la réponse inclut les partitions en commençant par la partition dont l'identifiant suit immédiatement le ShardId que vous avez indiqué.

Si vous spécifiez le type AT_TIMESTAMP ou FROM_TIMESTAMP_ID, vous devez également indiquer la valeur de la propriété optionnelle Timestamp. Si vous spécifiez le type AT_TIMESTAMP, toutes les partitions ouvertes à l'horodatage indiqué sont renvoyées. Si vous spécifiez le type FROM_TIMESTAMP, toutes les partitions commençant à partir de l'horodatage indiqué jusqu'à TIP sont renvoyées.

SELECT useridentity.sessioncontext.sessionissuer.username, 
useridentity.arn,eventname,useragent, count(*) FROM 
cloudtrail_logs WHERE Eventname IN ('DescribeStream')  AND 
eventtime
    BETWEEN ''
        AND ''
GROUP BY  useridentity.sessioncontext.sessionissuer.username,useridentity.arn,eventname,useragent
ORDER BY  count(*) DESC LIMIT 100