معرفی شرکت ها
aws-cdk.aws-msk-alpha-2.9.0a0
تبلیغات ما
مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.
مشاهده بیشتر
تبلیغات ما
مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.
مشاهده بیشتر
تبلیغات ما
مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.
مشاهده بیشتر
تبلیغات ما
مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.
مشاهده بیشتر
تبلیغات ما
مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.
مشاهده بیشتر
2.9.0a0
2.8.0a0
2.78.0a0
2.77.0a0
2.76.0a0
2.75.1a0
2.75.0a0
2.74.0a0
2.73.0a0
2.72.1a0
2.72.0a0
2.71.0a0
2.70.0a0
2.7.0a0
2.69.0a0
2.68.0a0
2.67.0a0
2.66.1a0
2.66.0a0
2.65.0a0
2.64.0a0
2.63.2a0
2.63.1a0
2.63.0a0
2.62.2a0
2.62.1a0
2.62.0a0
2.61.1a0
2.61.0a0
2.60.0a0
2.6.0a0
2.59.0a0
2.58.1a0
2.58.0a0
2.57.0a0
2.56.1a0
2.56.0a0
2.55.1a0
2.55.0a0
2.54.0a0
2.53.0a0
2.52.1a0
2.52.0a0
2.51.1a0
2.51.0a0
2.50.0a0
2.5.0a0
2.49.1a0
2.49.0a0
2.48.0a0
2.47.0a0
2.46.0a0
2.45.0a0
2.44.0a0
2.43.1a0
2.43.0a0
2.42.1a0
2.42.0a0
2.41.0a0
2.40.0a0
2.4.0a0
2.39.1a0
2.39.0a0
2.38.1a0
2.38.0a0
2.37.1a0
2.37.0a0
2.36.0a0
2.35.0a0
2.34.2a0
2.34.1a0
2.34.0a0
2.33.0a0
2.32.1a0
2.32.0a0
2.31.2a0
2.31.1a0
2.31.0a0
2.30.0a0
2.3.0a0
2.29.1a0
2.29.0a0
2.28.1a0
2.28.0a0
2.27.0a0
2.26.0a0
2.25.0a0
2.24.1a0
2.24.0a0
2.23.0a0
2.22.0a0
2.21.1a0
2.21.0a0
2.20.0a0
2.2.0a0
2.19.0a0
2.18.0a0
2.17.0a0
2.16.0a0
2.15.0a0
2.14.0a0
2.13.0a0
2.12.0a0
2.11.0a0
2.10.0a0
2.1.0a0
2.0.0rc24
2.0.0rc23
2.0.0a9
2.0.0a8
2.0.0a7
2.0.0a6
2.0.0a5
2.0.0a4
2.0.0a3
2.0.0a2
2.0.0a11
2.0.0a10
2.0.0a1
2.9.0a0
2.8.0a0
2.78.0a0
2.77.0a0
2.76.0a0
2.75.1a0
2.75.0a0
2.74.0a0
2.73.0a0
2.72.1a0
2.72.0a0
2.71.0a0
2.70.0a0
2.7.0a0
2.69.0a0
2.68.0a0
2.67.0a0
2.66.1a0
2.66.0a0
2.65.0a0
2.64.0a0
2.63.2a0
2.63.1a0
2.63.0a0
2.62.2a0
2.62.1a0
2.62.0a0
2.61.1a0
2.61.0a0
2.60.0a0
2.6.0a0
2.59.0a0
2.58.1a0
2.58.0a0
2.57.0a0
2.56.1a0
2.56.0a0
2.55.1a0
2.55.0a0
2.54.0a0
2.53.0a0
2.52.1a0
2.52.0a0
2.51.1a0
2.51.0a0
2.50.0a0
2.5.0a0
2.49.1a0
2.49.0a0
2.48.0a0
2.47.0a0
2.46.0a0
2.45.0a0
2.44.0a0
2.43.1a0
2.43.0a0
2.42.1a0
2.42.0a0
2.41.0a0
2.40.0a0
2.4.0a0
2.39.1a0
2.39.0a0
2.38.1a0
2.38.0a0
2.37.1a0
2.37.0a0
2.36.0a0
2.35.0a0
2.34.2a0
2.34.1a0
2.34.0a0
2.33.0a0
2.32.1a0
2.32.0a0
2.31.2a0
2.31.1a0
2.31.0a0
2.30.0a0
2.3.0a0
2.29.1a0
2.29.0a0
2.28.1a0
2.28.0a0
2.27.0a0
2.26.0a0
2.25.0a0
2.24.1a0
2.24.0a0
2.23.0a0
2.22.0a0
2.21.1a0
2.21.0a0
2.20.0a0
2.2.0a0
2.19.0a0
2.18.0a0
2.17.0a0
2.16.0a0
2.15.0a0
2.14.0a0
2.13.0a0
2.12.0a0
2.11.0a0
2.10.0a0
2.1.0a0
2.0.0rc24
2.0.0rc23
2.0.0a9
2.0.0a8
2.0.0a7
2.0.0a6
2.0.0a5
2.0.0a4
2.0.0a3
2.0.0a2
2.0.0a11
2.0.0a10
2.0.0a1
توضیحات
The CDK Construct Library for AWS::MSK
| ویژگی | مقدار |
|---|---|
| سیستم عامل | - |
| نام فایل | aws-cdk.aws-msk-alpha-2.9.0a0 |
| نام | aws-cdk.aws-msk-alpha |
| نسخه کتابخانه | 2.9.0a0 |
| نگهدارنده | [] |
| ایمیل نگهدارنده | [] |
| نویسنده | Amazon Web Services |
| ایمیل نویسنده | - |
| آدرس صفحه اصلی | https://github.com/aws/aws-cdk |
| آدرس اینترنتی | https://pypi.org/project/aws-cdk.aws-msk-alpha/ |
| مجوز | Apache-2.0 |
# Amazon Managed Streaming for Apache Kafka Construct Library
<!--BEGIN STABILITY BANNER-->---
> The APIs of higher level constructs in this module are experimental and under active development.
> They are subject to non-backward compatible changes or removal in any future version. These are
> not subject to the [Semantic Versioning](https://semver.org/) model and breaking changes will be
> announced in the release notes. This means that while you may use them, you may need to update
> your source code when upgrading to a newer version of this package.
---
<!--END STABILITY BANNER-->
[Amazon MSK](https://aws.amazon.com/msk/) is a fully managed service that makes it easy for you to build and run applications that use Apache Kafka to process streaming data.
The following example creates an MSK Cluster.
```python
# vpc: ec2.Vpc
cluster = msk.Cluster(self, "Cluster",
cluster_name="myCluster",
kafka_version=msk.KafkaVersion.V2_8_1,
vpc=vpc
)
```
## Allowing Connections
To control who can access the Cluster, use the `.connections` attribute. For a list of ports used by MSK, refer to the [MSK documentation](https://docs.aws.amazon.com/msk/latest/developerguide/client-access.html#port-info).
```python
# vpc: ec2.Vpc
cluster = msk.Cluster(self, "Cluster",
cluster_name="myCluster",
kafka_version=msk.KafkaVersion.V2_8_1,
vpc=vpc
)
cluster.connections.allow_from(
ec2.Peer.ipv4("1.2.3.4/8"),
ec2.Port.tcp(2181))
cluster.connections.allow_from(
ec2.Peer.ipv4("1.2.3.4/8"),
ec2.Port.tcp(9094))
```
## Cluster Endpoints
You can use the following attributes to get a list of the Kafka broker or ZooKeeper node endpoints
```python
# cluster: msk.Cluster
CfnOutput(self, "BootstrapBrokers", value=cluster.bootstrap_brokers)
CfnOutput(self, "BootstrapBrokersTls", value=cluster.bootstrap_brokers_tls)
CfnOutput(self, "BootstrapBrokersSaslScram", value=cluster.bootstrap_brokers_sasl_scram)
CfnOutput(self, "BootstrapBrokerStringSaslIam", value=cluster.bootstrap_brokers_sasl_iam)
CfnOutput(self, "ZookeeperConnection", value=cluster.zookeeper_connection_string)
CfnOutput(self, "ZookeeperConnectionTls", value=cluster.zookeeper_connection_string_tls)
```
## Importing an existing Cluster
To import an existing MSK cluster into your CDK app use the `.fromClusterArn()` method.
```python
cluster = msk.Cluster.from_cluster_arn(self, "Cluster", "arn:aws:kafka:us-west-2:1234567890:cluster/a-cluster/11111111-1111-1111-1111-111111111111-1")
```
## Client Authentication
[MSK supports](https://docs.aws.amazon.com/msk/latest/developerguide/kafka_apis_iam.html) the following authentication mechanisms.
### TLS
To enable client authentication with TLS set the `certificateAuthorityArns` property to reference your ACM Private CA. [More info on Private CAs.](https://docs.aws.amazon.com/msk/latest/developerguide/msk-authentication.html)
```python
import aws_cdk.aws_acmpca as acmpca
# vpc: ec2.Vpc
cluster = msk.Cluster(self, "Cluster",
cluster_name="myCluster",
kafka_version=msk.KafkaVersion.V2_8_1,
vpc=vpc,
encryption_in_transit=msk.EncryptionInTransitConfig(
client_broker=msk.ClientBrokerEncryption.TLS
),
client_authentication=msk.ClientAuthentication.tls(
certificate_authorities=[
acmpca.CertificateAuthority.from_certificate_authority_arn(self, "CertificateAuthority", "arn:aws:acm-pca:us-west-2:1234567890:certificate-authority/11111111-1111-1111-1111-111111111111")
]
)
)
```
### SASL/SCRAM
Enable client authentication with [SASL/SCRAM](https://docs.aws.amazon.com/msk/latest/developerguide/msk-password.html):
```python
# vpc: ec2.Vpc
cluster = msk.Cluster(self, "cluster",
cluster_name="myCluster",
kafka_version=msk.KafkaVersion.V2_8_1,
vpc=vpc,
encryption_in_transit=msk.EncryptionInTransitConfig(
client_broker=msk.ClientBrokerEncryption.TLS
),
client_authentication=msk.ClientAuthentication.sasl(
scram=True
)
)
```
### SASL/IAM
Enable client authentication with [IAM](https://docs.aws.amazon.com/msk/latest/developerguide/iam-access-control.html):
```python
# vpc: ec2.Vpc
cluster = msk.Cluster(self, "cluster",
cluster_name="myCluster",
kafka_version=msk.KafkaVersion.V2_8_1,
vpc=vpc,
encryption_in_transit=msk.EncryptionInTransitConfig(
client_broker=msk.ClientBrokerEncryption.TLS
),
client_authentication=msk.ClientAuthentication.sasl(
iam=True
)
)
```
### SASL/IAM + TLS
Enable client authentication with [IAM](https://docs.aws.amazon.com/msk/latest/developerguide/iam-access-control.html)
as well as enable client authentication with TLS by setting the `certificateAuthorityArns` property to reference your ACM Private CA. [More info on Private CAs.](https://docs.aws.amazon.com/msk/latest/developerguide/msk-authentication.html)
```python
import aws_cdk.aws_acmpca as acmpca
# vpc: ec2.Vpc
cluster = msk.Cluster(self, "Cluster",
cluster_name="myCluster",
kafka_version=msk.KafkaVersion.V2_8_1,
vpc=vpc,
encryption_in_transit=msk.EncryptionInTransitConfig(
client_broker=msk.ClientBrokerEncryption.TLS
),
client_authentication=msk.ClientAuthentication.sasl_tls(
iam=True,
certificate_authorities=[
acmpca.CertificateAuthority.from_certificate_authority_arn(self, "CertificateAuthority", "arn:aws:acm-pca:us-west-2:1234567890:certificate-authority/11111111-1111-1111-1111-111111111111")
]
)
)
```
## Logging
You can deliver Apache Kafka broker logs to one or more of the following destination types:
Amazon CloudWatch Logs, Amazon S3, Amazon Kinesis Data Firehose.
To configure logs to be sent to an S3 bucket, provide a bucket in the `logging` config.
```python
# vpc: ec2.Vpc
# bucket: s3.IBucket
cluster = msk.Cluster(self, "cluster",
cluster_name="myCluster",
kafka_version=msk.KafkaVersion.V2_8_1,
vpc=vpc,
logging=msk.BrokerLogging(
s3=msk.S3LoggingConfiguration(
bucket=bucket
)
)
)
```
When the S3 destination is configured, AWS will automatically create an S3 bucket policy
that allows the service to write logs to the bucket. This makes it impossible to later update
that bucket policy. To have CDK create the bucket policy so that future updates can be made,
the `@aws-cdk/aws-s3:createDefaultLoggingPolicy` [feature flag](https://docs.aws.amazon.com/cdk/v2/guide/featureflags.html) can be used. This can be set
in the `cdk.json` file.
```json
{
"context": {
"@aws-cdk/aws-s3:createDefaultLoggingPolicy": true
}
}
```
نیازمندی
| مقدار | نام |
|---|---|
| ==2.78.0 | aws-cdk-lib |
| <11.0.0,>=10.0.0 | constructs |
| <2.0.0,>=1.78.1 | jsii |
| >=0.0.3 | publication |
| ~=2.13.3 | typeguard |
زبان مورد نیاز
| مقدار | نام |
|---|---|
| ~=3.7 | Python |
نحوه نصب
نصب پکیج whl aws-cdk.aws-msk-alpha-2.9.0a0:
pip install aws-cdk.aws-msk-alpha-2.9.0a0.whl
نصب پکیج tar.gz aws-cdk.aws-msk-alpha-2.9.0a0:
pip install aws-cdk.aws-msk-alpha-2.9.0a0.tar.gz