2525"""
2626
2727import argparse
28- # [START dependencies ]
28+ # [START bigtable_hw_imports ]
2929import datetime
3030
3131from google .cloud import bigtable
3232from google .cloud .bigtable import column_family
3333from google .cloud .bigtable import row_filters
34- # [END dependencies ]
34+ # [END bigtable_hw_imports ]
3535
3636
3737def main (project_id , instance_id , table_id ):
38- # [START connecting_to_bigtable ]
38+ # [START bigtable_hw_connect ]
3939 # The client must be created with admin=True because it will create a
4040 # table.
4141 client = bigtable .Client (project = project_id , admin = True )
4242 instance = client .instance (instance_id )
43- # [END connecting_to_bigtable ]
43+ # [END bigtable_hw_connect ]
4444
45- # [START creating_a_table ]
45+ # [START bigtable_hw_create_table ]
4646 print ('Creating the {} table.' .format (table_id ))
4747 table = instance .table (table_id )
4848
@@ -56,9 +56,9 @@ def main(project_id, instance_id, table_id):
5656 table .create (column_families = column_families )
5757 else :
5858 print ("Table {} already exists." .format (table_id ))
59- # [END creating_a_table ]
59+ # [END bigtable_hw_create_table ]
6060
61- # [START writing_rows ]
61+ # [START bigtable_hw_write_rows ]
6262 print ('Writing some greetings to the table.' )
6363 greetings = ['Hello World!' , 'Hello Cloud Bigtable!' , 'Hello Python!' ]
6464 rows = []
@@ -82,36 +82,36 @@ def main(project_id, instance_id, table_id):
8282 timestamp = datetime .datetime .utcnow ())
8383 rows .append (row )
8484 table .mutate_rows (rows )
85- # [END writing_rows ]
85+ # [END bigtable_hw_write_rows ]
8686
87- # [START creating_a_filter ]
87+ # [START bigtable_hw_create_filter ]
8888 # Create a filter to only retrieve the most recent version of the cell
8989 # for each column accross entire row.
9090 row_filter = row_filters .CellsColumnLimitFilter (1 )
91- # [END creating_a_filter ]
91+ # [END bigtable_hw_create_filter ]
9292
93- # [START getting_a_row ]
93+ # [START bigtable_hw_get_with_filter ]
9494 print ('Getting a single greeting by row key.' )
9595 key = 'greeting0' .encode ()
9696
9797 row = table .read_row (key , row_filter )
9898 cell = row .cells [column_family_id ][column ][0 ]
9999 print (cell .value .decode ('utf-8' ))
100- # [END getting_a_row ]
100+ # [END bigtable_hw_get_with_filter ]
101101
102- # [START scanning_all_rows ]
102+ # [START bigtable_hw_scan_with_filter ]
103103 print ('Scanning for all greetings:' )
104104 partial_rows = table .read_rows (filter_ = row_filter )
105105
106106 for row in partial_rows :
107107 cell = row .cells [column_family_id ][column ][0 ]
108108 print (cell .value .decode ('utf-8' ))
109- # [END scanning_all_rows ]
109+ # [END bigtable_hw_scan_with_filter ]
110110
111- # [START deleting_a_table ]
111+ # [START bigtable_hw_delete_table ]
112112 print ('Deleting the {} table.' .format (table_id ))
113113 table .delete ()
114- # [END deleting_a_table ]
114+ # [END bigtable_hw_delete_table ]
115115
116116
117117if __name__ == '__main__' :
0 commit comments