1111# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
1212# See the License for the specific language governing permissions and
1313# limitations under the License.
14- # [START run_events_pubsub_server_setup ]
14+ # [START run_events_gcs_server_setup ]
1515import os
1616
1717from flask import Flask , request
2020required_fields = ['Ce-Id' , 'Ce-Source' , 'Ce-Type' , 'Ce-Specversion' ]
2121
2222app = Flask (__name__ )
23- # [END run_events_pubsub_server_setup ]
23+ # [END run_events_gcs_server_setup ]
2424
2525
26- # [START run_events_pubsub_handler ]
26+ # [START run_events_gcs_handler ]
2727@app .route ('/' , methods = ['POST' ])
2828def index ():
2929 for field in required_fields :
@@ -40,10 +40,10 @@ def index():
4040 ce_subject = request .headers .get ('Ce-Subject' )
4141 print (f'GCS CloudEvent type: { ce_subject } ' )
4242 return (f'GCS CloudEvent type: { ce_subject } ' , 200 )
43- # [END run_events_pubsub_handler ]
43+ # [END run_events_gcs_handler ]
4444
4545
46- # [START run_events_pubsub_server ]
46+ # [START run_events_gcs_server ]
4747if __name__ == "__main__" :
4848 app .run (debug = True , host = '0.0.0.0' , port = int (os .environ .get ('PORT' , 8080 )))
49- # [END run_events_pubsub_server ]
49+ # [END run_events_gcs_server ]
0 commit comments