Есть ли способ рассказать, что такое состояние осколка, независимо от того, ОТКРЫТО, ЗАКРЫТО или ВЫЯВЛЕН? Единственный способ, которым я смог определить эту информацию, похоже, пытается выполнить операцию на осколке.Как сообщить статус осколка Кинесиса?
ответ
Вы можете использовать Amazon Web Services Java SDK: https://github.com/aws/aws-sdk-java
Есть много полезных методов для доступа к ресурсам.
Редактировать: Извините, я неправильно понял вопрос. Вы не можете получить доступ к статусу осколка напрямую (пока). Но есть трюк: у закрытого осколка всегда есть «Ending Sequence Number». Вы можете взломать этот путь.
Выдержка из Javadoc;
общественности Строка getEndingSequenceNumber()
Конечный порядковый номер диапазона. Осколки, находящиеся в состоянии ОТКРЫТО, имеют порядковый номер нулевой последовательности.
import com.amazonaws.auth.BasicAWSCredentials;
import com.amazonaws.services.kinesis.AmazonKinesis;
import com.amazonaws.services.kinesis.AmazonKinesisClient;
import com.amazonaws.services.kinesis.model.DescribeStreamRequest;
import com.amazonaws.services.kinesis.model.DescribeStreamResult;
import com.amazonaws.services.kinesis.model.ListStreamsResult;
public class KinesisSandbox {
public static void main(String[] args) {
try {
String amazonKey = "x";
String amazonSecret = "y";
AmazonKinesis client = new AmazonKinesisClient(new BasicAWSCredentials(amazonKey, amazonSecret));
ListStreamsResult listStreamsResult = client.listStreams();
System.out.println("\nlistStreamsResult: " + listStreamsResult);
String streamName = listStreamsResult.getStreamNames().get(0);
DescribeStreamRequest describeStreamRequest = new DescribeStreamRequest();
describeStreamRequest.setStreamName(streamName);
DescribeStreamResult describeStreamResult = client.describeStream(describeStreamRequest);
System.out.println("\n describeStreamResult.getStreamDescription().getStreamStatus(): "
+ describeStreamResult.getStreamDescription().getStreamStatus());
// System.out.println("\ndescribeStreamResult: " + describeStreamResult);
List<Shard> shards = describeStreamResult.getStreamDescription().getShards();
for (int i = 0; i < shards.size(); i++) {
Shard shard = shards.get(i);
if (shard.getSequenceNumberRange().getEndingSequenceNumber() == null) {
System.out.println("shard(" + i + "): " + shard.getShardId() + " is OPEN.");
} else {
System.out.println("shard(" + i + "): " + shard.getShardId() + " is CLOSED.");
}
}
} catch (Exception e) {
e.printStackTrace();
}
}
}
-
Извините, это статус статуса потока, а не осколка. – thyme
О, извините, я пропустил эту часть. Насколько я знаю, вы не можете получить доступ к статусу осколка напрямую (пока). Но есть трюк: у закрытого осколка всегда есть «EndingSequenceNumber». Вы можете взломать этот путь. http://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/kinesis/model/SequenceNumberRange.html#getEndingSequenceNumber() – az3
- 1. Как сообщить статус уведомления оконного телефона MPNS
- 2. Для 32-битного осколка whats размер предел каждого осколка?
- 3. Избавьтесь от неназначенного осколка
- 4. Mongodb выбрать ключ осколка
- 5. составные границы блоков ключей осколка
- 6. как сбалансировать MongoDB после добавления осколка
- 7. Как указать хешированный ключ осколка, используя mongoengine?
- 8. Как MongoDB определяет тип ключа осколка?
- 9. Добавить копию осколка в SolrCloud
- 10. MongoDB соединения осколка ключевой стратегия
- 11. удаление осколка из базы mongo
- 12. MongoDB хранит данные только для первичного осколка в случае выбора пометки осколка ключа
- 13. Упругий поиск - Максимальный размер осколка
- 14. ElasticSearch - Определение максимального размера осколка
- 15. Размер осколка в 32-битном?
- 16. Сообщить об ошибке Сообщить об ошибке Сообщить об ошибке Сообщить об ошибке Сообщить об ошибке Сообщить об ошибке Сообщить об ошибке Сообщить об ошибке
- 17. Как сообщить об исключении и продолжить
- 18. Как сообщить данные J48
- 19. Solr API для получения статуса лидера/реплики осколка
- 20. Передвижной ящик и два осколка панели
- 21. Является ли контрольная точка KCL уникальной для приложения/осколка или всего осколка?
- 22. Что происходит при добавлении нового осколка в кластере с использованием хэшированного осколка?
- 23. Ошибка при выпуске db.collection.getShardDistribution() после удаления осколка
- 24. Предварительно сплит на компаунде Ключ осколка
- 25. Извлеките все документы из куска монго-осколка
- 26. хороший MongoDB ключ осколка для «домена» документа
- 27. Выбор правильного ключа осколка в MongoDB
- 28. Выбор ключа осколка для размещенной вики-системы
- 29. Snackbar не работает в осколка класса
- 30. Solr 4 Добавление осколка к существующему кластеру
Какой язык программирования вы используете? – az3
Не имеет значения. Мне интересно, есть ли способ получить эту информацию через API. – thyme