in infrastructure/app_stack.py [0:0]
def create_cassandra_table(self, table_name, keyspace_name, keyspace_ref, partitionkey_columns={}, clustering_key_columns={}, regular_columns={}, billing_mode={}):
properties = {'KeyspaceName': keyspace_ref, 'TableName': table_name,}
if partitionkey_columns:
properties.update({'PartitionKeyColumns': partitionkey_columns})
if clustering_key_columns:
properties.update({'ClusteringKeyColumns': clustering_key_columns})
if regular_columns:
properties.update({'RegularColumns': regular_columns})
if billing_mode:
properties.update(billing_mode)
resource = _core.CfnResource(self,
table_name,
type='AWS::Cassandra::Table',
properties=properties,
)
return resource, _core.Stack.format_arn(self,
service='cassandra',
resource='keyspace/{}/table'.format(keyspace_ref),
sep='/',
resource_name=table_name)