Untuk membatasi akses pengguna dalam project atau organisasi, Anda dapat menggunakan peran Identity and Access Management (IAM) untuk Dataflow. Anda dapat mengontrol akses ke resource terkait Dataflow, bukan memberikan peran Viewer, Editor, atau Pemilik kepada pengguna untuk seluruh project Google Cloud Platform.
Halaman ini berfokus pada cara menggunakan peran IAM Dataflow. Untuk mengetahui deskripsi mendetail tentang IAM dan fitur-fiturnya, lihat dokumentasi IAM.
Setiap metode Dataflow mengharuskan pemanggil memiliki izin yang diperlukan. Untuk mengetahui daftar izin dan peran yang didukung Dataflow, lihat bagian berikut.
Izin dan peran
Bagian ini merangkum izin dan peran yang didukung IAM Dataflow.
Izin yang diperlukan
Tabel berikut berisi izin yang harus dimiliki pemanggil untuk memanggil setiap metode:
| Metode | Izin yang Diperlukan |
|---|---|
dataflow.jobs.create |
dataflow.jobs.create |
dataflow.jobs.cancel |
dataflow.jobs.cancel |
dataflow.jobs.updateContents |
dataflow.jobs.updateContents |
dataflow.jobs.list |
dataflow.jobs.list |
dataflow.jobs.get |
dataflow.jobs.get |
dataflow.messages.list |
dataflow.messages.list |
dataflow.metrics.get |
dataflow.metrics.get |
dataflow.jobs.snapshot |
dataflow.jobs.snapshot |
Peran
Tabel berikut berisi peran IAM Dataflow dengan daftar terkait izin terkait Dataflow yang disertakan dalam setiap peran. Setiap izin berlaku untuk jenis resource tertentu. Untuk melihat daftar izin, buka halaman Peran di Google Cloud konsol.
(
Minimal role for creating and managing dataflow jobs.
(
Provides the permissions necessary to execute and manipulate
Dataflow jobs.
Lowest-level resources where you can grant this role:
(
Gives Cloud Dataflow service account access to managed resources. Includes access to service accounts.
(
Provides read-only access to all Dataflow-related
resources.
Lowest-level resources where you can grant this role: (
Provides the permissions necessary for a Compute Engine service
account to execute work units for a Dataflow pipeline.
Lowest-level resources where you can grant this role:
Role
Permissions
Dataflow Admin
roles/)
cloudbuild.builds.createcloudbuild.builds.getcloudbuild.builds.listcloudbuild.builds.updatecloudbuild.locations.*
cloudbuild.locations.getcloudbuild.locations.listcloudbuild.operations.*
cloudbuild.operations.getcloudbuild.operations.listcloudkms.keyHandles.*
cloudkms.keyHandles.createcloudkms.keyHandles.getcloudkms.keyHandles.listcloudkms.operations.getcloudkms.compute.machineTypes.getcompute.projects.getcompute.regions.listcompute.zones.listdataflow.jobs.*
dataflow.jobs.canceldataflow.jobs.createdataflow.jobs.getdataflow.jobs.listdataflow.jobs.snapshotdataflow.jobs.updateContentsdataflow.messages.listdataflow.metrics.getdataflow.snapshots.*
dataflow.snapshots.deletedataflow.snapshots.getdataflow.snapshots.listrecommender.
recommender.recommender.recommender.remotebuildexecution.blobs.getresourcemanager.projects.getresourcemanager.projects.liststorage.buckets.getstorage.objects.createstorage.objects.getstorage.objects.list
Dataflow Developer
roles/)
cloudbuild.builds.createcloudbuild.builds.getcloudbuild.builds.listcloudbuild.builds.updatecloudbuild.locations.*
cloudbuild.locations.getcloudbuild.locations.listcloudbuild.operations.*
cloudbuild.operations.getcloudbuild.operations.listcloudkms.keyHandles.*
cloudkms.keyHandles.createcloudkms.keyHandles.getcloudkms.keyHandles.listcloudkms.operations.getcloudkms.compute.projects.getcompute.regions.listcompute.zones.listdataflow.jobs.*
dataflow.jobs.canceldataflow.jobs.createdataflow.jobs.getdataflow.jobs.listdataflow.jobs.snapshotdataflow.jobs.updateContentsdataflow.messages.listdataflow.metrics.getdataflow.snapshots.*
dataflow.snapshots.deletedataflow.snapshots.getdataflow.snapshots.listrecommender.
recommender.recommender.recommender.remotebuildexecution.blobs.getresourcemanager.projects.getresourcemanager.projects.list
Cloud Dataflow Service Agent
roles/)
backupdr.backupdr.backupdr.backupdr.backupdr.backupdr.backupdr.backupdr.backupdr.backupdr.backupdr.backupdr.backupPlans.getbackupdr.backupPlans.listbackupdr.backupdr.backupdr.backupVaults.getbackupdr.backupVaults.listbackupdr.locations.listbackupdr.operations.getbackupdr.operations.listbackupdr.bigquery.bireservations.*
bigquery.bireservations.getbigquery.bireservations.updatebigquery.capacityCommitments.*
bigquery.bigquery.bigquery.bigquery.bigquery.bigquery.config.*
bigquery.config.getbigquery.config.updatebigquery.connections.*
bigquery.connections.createbigquery.connections.delegatebigquery.connections.deletebigquery.connections.getbigquery.bigquery.connections.listbigquery.bigquery.connections.updatebigquery.connections.updateTagbigquery.connections.usebigquery.dataPolicies.attachbigquery.dataPolicies.createbigquery.dataPolicies.deletebigquery.dataPolicies.getbigquery.bigquery.dataPolicies.listbigquery.bigquery.dataPolicies.updatebigquery.datasets.*
bigquery.datasets.createbigquery.bigquery.datasets.deletebigquery.bigquery.datasets.getbigquery.datasets.getIamPolicybigquery.datasets.linkbigquery.bigquery.bigquery.bigquery.datasets.setIamPolicybigquery.datasets.updatebigquery.datasets.updateTagbigquery.jobs.*
bigquery.jobs.createbigquery.bigquery.jobs.deletebigquery.jobs.getbigquery.jobs.listbigquery.jobs.listAllbigquery.bigquery.jobs.updatebigquery.models.*
bigquery.models.createbigquery.models.deletebigquery.models.exportbigquery.models.getDatabigquery.models.getMetadatabigquery.models.listbigquery.models.updateDatabigquery.models.updateMetadatabigquery.models.updateTagbigquery.objectRefs.*
bigquery.objectRefs.readbigquery.objectRefs.writebigquery.readsessions.*
bigquery.readsessions.createbigquery.readsessions.getDatabigquery.readsessions.updatebigquery.
bigquery.bigquery.bigquery.bigquery.bigquery.reservationGroups.*
bigquery.bigquery.bigquery.reservationGroups.getbigquery.bigquery.reservations.*
bigquery.reservations.createbigquery.reservations.deletebigquery.reservations.getbigquery.reservations.listbigquery.bigquery.reservations.updatebigquery.reservations.usebigquery.routines.*
bigquery.routines.createbigquery.routines.deletebigquery.routines.getbigquery.routines.listbigquery.routines.updatebigquery.routines.updateTagbigquery.bigquery.bigquery.rowAccessPolicies.getbigquery.bigquery.bigquery.bigquery.bigquery.bigquery.savedqueries.*
bigquery.savedqueries.createbigquery.savedqueries.deletebigquery.savedqueries.getbigquery.savedqueries.listbigquery.savedqueries.updatebigquery.tables.*
bigquery.tables.createbigquery.tables.createIndexbigquery.tables.createSnapshotbigquery.bigquery.tables.deletebigquery.tables.deleteIndexbigquery.tables.deleteSnapshotbigquery.bigquery.tables.exportbigquery.tables.getbigquery.tables.getDatabigquery.tables.getIamPolicybigquery.tables.listbigquery.bigquery.bigquery.tables.replicateDatabigquery.bigquery.tables.setCategorybigquery.bigquery.tables.setIamPolicybigquery.tables.updatebigquery.tables.updateDatabigquery.tables.updateIndexbigquery.tables.updateTagbigquery.transfers.*
bigquery.transfers.getbigquery.transfers.updatebigquerymigration.clouddebugger.breakpoints.listclouddebugger.clouddebugger.clouddebugger.debuggees.createcloudnotifications.compute.acceleratorTypes.*
compute.acceleratorTypes.getcompute.acceleratorTypes.listcompute.addresses.*
compute.addresses.createcompute.compute.compute.addresses.deletecompute.compute.compute.addresses.getcompute.addresses.listcompute.compute.compute.addresses.setLabelscompute.addresses.usecompute.addresses.useInternalcompute.autoscalers.*
compute.autoscalers.createcompute.autoscalers.deletecompute.autoscalers.getcompute.autoscalers.listcompute.autoscalers.updatecompute.backendBuckets.*
compute.compute.backendBuckets.createcompute.compute.backendBuckets.deletecompute.compute.compute.backendBuckets.getcompute.compute.backendBuckets.listcompute.compute.compute.compute.compute.backendBuckets.updatecompute.backendBuckets.usecompute.backendServices.*
compute.compute.backendServices.createcompute.compute.backendServices.deletecompute.compute.compute.backendServices.getcompute.compute.backendServices.listcompute.compute.compute.compute.compute.backendServices.updatecompute.backendServices.usecompute.crossSiteNetworks.*
compute.compute.compute.crossSiteNetworks.getcompute.crossSiteNetworks.listcompute.compute.diskSettings.*
compute.diskSettings.getcompute.diskSettings.updatecompute.diskTypes.*
compute.diskTypes.getcompute.diskTypes.listcompute.disks.*
compute.compute.disks.createcompute.disks.createSnapshotcompute.disks.createTagBindingcompute.disks.deletecompute.disks.deleteTagBindingcompute.disks.getcompute.disks.getIamPolicycompute.disks.listcompute.compute.disks.listTagBindingscompute.compute.disks.resizecompute.disks.setIamPolicycompute.disks.setLabelscompute.compute.compute.compute.disks.updatecompute.disks.updateKmsKeycompute.disks.usecompute.disks.useReadOnlycompute.externalVpnGateways.*
compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.firewallPolicies.getcompute.firewallPolicies.listcompute.compute.compute.firewallPolicies.usecompute.firewalls.getcompute.firewalls.listcompute.compute.compute.forwardingRules.*
compute.forwardingRules.createcompute.compute.forwardingRules.deletecompute.compute.forwardingRules.getcompute.forwardingRules.listcompute.compute.compute.compute.compute.compute.compute.compute.compute.forwardingRules.updatecompute.forwardingRules.usecompute.globalAddresses.*
compute.globalAddresses.createcompute.compute.compute.globalAddresses.deletecompute.compute.compute.globalAddresses.getcompute.globalAddresses.listcompute.compute.compute.compute.globalAddresses.usecompute.
compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.
compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.globalOperations.getcompute.globalOperations.listcompute.compute.compute.compute.compute.healthChecks.*
compute.healthChecks.createcompute.compute.healthChecks.deletecompute.compute.healthChecks.getcompute.healthChecks.listcompute.compute.compute.healthChecks.updatecompute.healthChecks.usecompute.compute.httpHealthChecks.*
compute.compute.compute.compute.compute.httpHealthChecks.getcompute.httpHealthChecks.listcompute.compute.compute.compute.httpHealthChecks.usecompute.compute.httpsHealthChecks.*
compute.compute.compute.compute.compute.httpsHealthChecks.getcompute.httpsHealthChecks.listcompute.compute.compute.compute.httpsHealthChecks.usecompute.compute.images.*
compute.images.createcompute.compute.images.deletecompute.compute.images.deprecatecompute.images.getcompute.images.getFromFamilycompute.images.getIamPolicycompute.images.listcompute.compute.images.listTagBindingscompute.images.setIamPolicycompute.images.setLabelscompute.images.updatecompute.images.useReadOnlycompute.
compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.instanceGroups.*
compute.instanceGroups.createcompute.compute.instanceGroups.deletecompute.compute.instanceGroups.getcompute.instanceGroups.listcompute.compute.compute.instanceGroups.updatecompute.instanceGroups.usecompute.instanceSettings.getcompute.instanceTemplates.*
compute.compute.compute.instanceTemplates.getcompute.compute.instanceTemplates.listcompute.compute.compute.instances.*
compute.compute.compute.compute.instances.attachDiskcompute.instances.createcompute.compute.instances.deletecompute.compute.compute.compute.instances.detachDiskcompute.instances.getcompute.compute.compute.instances.getIamPolicycompute.compute.compute.compute.compute.instances.listcompute.compute.compute.compute.instances.osAdminLogincompute.instances.osLogincompute.compute.compute.instances.resetcompute.instances.resumecompute.compute.compute.compute.instances.setIamPolicycompute.instances.setLabelscompute.compute.compute.instances.setMetadatacompute.compute.instances.setNamecompute.compute.compute.compute.compute.compute.instances.setTagscompute.compute.instances.startcompute.compute.instances.stopcompute.instances.suspendcompute.instances.updatecompute.compute.compute.compute.compute.compute.compute.instances.usecompute.instances.useReadOnlycompute.instantSnapshots.*
compute.compute.compute.compute.instantSnapshots.getcompute.compute.instantSnapshots.listcompute.compute.compute.compute.
compute.compute.compute.compute.compute.compute.
compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.interconnectGroups.*
compute.compute.compute.interconnectGroups.getcompute.compute.compute.
compute.compute.compute.
compute.compute.compute.interconnects.*
compute.interconnects.createcompute.compute.interconnects.deletecompute.compute.interconnects.getcompute.compute.interconnects.listcompute.compute.compute.compute.interconnects.updatecompute.interconnects.usecompute.licenseCodes.*
compute.licenseCodes.getcompute.compute.licenseCodes.listcompute.compute.licenses.*
compute.licenses.createcompute.licenses.deletecompute.licenses.getcompute.licenses.getIamPolicycompute.licenses.listcompute.licenses.setIamPolicycompute.licenses.updatecompute.machineImages.*
compute.machineImages.createcompute.machineImages.deletecompute.machineImages.getcompute.compute.machineImages.listcompute.compute.compute.compute.machineTypes.*
compute.machineTypes.getcompute.machineTypes.listcompute.multiMig.*
compute.multiMig.createcompute.multiMig.deletecompute.multiMig.getcompute.multiMig.listcompute.networkAttachments.*
compute.compute.compute.compute.compute.networkAttachments.getcompute.compute.compute.compute.compute.compute.compute.networkAttachments.usecompute.
compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.networkProfiles.*
compute.networkProfiles.getcompute.networkProfiles.listcompute.networks.*
compute.networks.accesscompute.networks.addPeeringcompute.networks.createcompute.compute.networks.deletecompute.compute.networks.getcompute.compute.compute.networks.listcompute.compute.compute.compute.networks.mirrorcompute.networks.removePeeringcompute.compute.compute.compute.networks.updatecompute.networks.updatePeeringcompute.networks.updatePolicycompute.networks.usecompute.networks.useExternalIpcompute.packetMirrorings.getcompute.packetMirrorings.listcompute.compute.compute.projects.getcompute.compute.compute.compute.compute.compute.compute.compute.regionBackendBuckets.*
compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.
compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.
compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.
compute.compute.compute.compute.compute.compute.
compute.compute.compute.compute.compute.compute.compute.regionHealthChecks.*
compute.compute.compute.compute.compute.regionHealthChecks.getcompute.compute.compute.compute.compute.regionHealthChecks.usecompute.compute.regionHealthSources.*
compute.compute.compute.compute.compute.compute.
compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.
compute.compute.compute.compute.compute.compute.compute.
compute.compute.compute.compute.compute.compute.compute.regionOperations.getcompute.regionOperations.listcompute.compute.compute.compute.compute.compute.compute.compute.compute.compute.regionSslPolicies.*
compute.compute.compute.compute.compute.regionSslPolicies.getcompute.regionSslPolicies.listcompute.compute.compute.compute.compute.regionSslPolicies.usecompute.
compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.
compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.
compute.compute.compute.compute.compute.compute.compute.compute.compute.compute.regionUrlMaps.*
compute.regionUrlMaps.createcompute.compute.regionUrlMaps.deletecompute.compute.regionUrlMaps.getcompute.compute.regionUrlMaps.listcompute.compute.compute.regionUrlMaps.updatecompute.regionUrlMaps.usecompute.regionUrlMaps.validatecompute.regions.*
compute.regions.getcompute.regions.listcompute.reservationBlocks.getcompute.reservationBlocks.listcompute.reservationSubBlocks.*
compute.compute.compute.compute.compute.reservations.getcompute.reservations.listcompute.resourcePolicies.*
compute.compute.compute.resourcePolicies.getcompute.compute.resourcePolicies.listcompute.compute.compute.resourcePolicies.usecompute.compute.routers.*
compute.routers.createcompute.compute.routers.deletecompute.compute.compute.routers.getcompute.routers.getRoutePolicycompute.routers.listcompute.routers.listBgpRoutescompute.compute.compute.compute.routers.updatecompute.compute.routers.usecompute.routes.*
compute.routes.createcompute.compute.routes.deletecompute.compute.routes.getcompute.routes.listcompute.compute.routes.listTagBindingscompute.securityPolicies.getcompute.securityPolicies.listcompute.compute.compute.securityPolicies.usecompute.serviceAttachments.*
compute.compute.compute.compute.compute.serviceAttachments.getcompute.compute.compute.compute.compute.compute.compute.serviceAttachments.usecompute.snapshots.*
compute.snapshots.createcompute.compute.snapshots.deletecompute.compute.snapshots.getcompute.snapshots.getIamPolicycompute.snapshots.listcompute.compute.compute.snapshots.setIamPolicycompute.snapshots.setLabelscompute.snapshots.updateKmsKeycompute.snapshots.useReadOnlycompute.sslCertificates.getcompute.sslCertificates.listcompute.compute.compute.sslPolicies.*
compute.sslPolicies.createcompute.compute.sslPolicies.deletecompute.compute.sslPolicies.getcompute.sslPolicies.listcompute.compute.compute.compute.sslPolicies.updatecompute.sslPolicies.usecompute.storagePools.*
compute.storagePools.createcompute.storagePools.deletecompute.storagePools.getcompute.compute.storagePools.listcompute.compute.storagePools.updatecompute.storagePools.usecompute.subnetworks.*
compute.subnetworks.createcompute.compute.subnetworks.deletecompute.compute.compute.subnetworks.getcompute.compute.subnetworks.listcompute.compute.compute.subnetworks.mirrorcompute.compute.compute.subnetworks.updatecompute.subnetworks.usecompute.compute.compute.targetGrpcProxies.*
compute.compute.compute.compute.compute.targetGrpcProxies.getcompute.targetGrpcProxies.listcompute.compute.compute.compute.targetGrpcProxies.usecompute.targetHttpProxies.*
compute.compute.compute.compute.compute.targetHttpProxies.getcompute.targetHttpProxies.listcompute.compute.compute.compute.compute.targetHttpProxies.usecompute.targetHttpsProxies.*
compute.compute.compute.compute.compute.targetHttpsProxies.getcompute.compute.compute.compute.compute.compute.compute.compute.compute.compute.targetHttpsProxies.usecompute.targetInstances.*
compute.targetInstances.createcompute.compute.targetInstances.deletecompute.compute.targetInstances.getcompute.targetInstances.listcompute.compute.compute.compute.targetInstances.usecompute.targetPools.*
compute.compute.compute.targetPools.createcompute.compute.targetPools.deletecompute.compute.targetPools.getcompute.targetPools.listcompute.compute.compute.compute.compute.compute.targetPools.updatecompute.targetPools.usecompute.targetSslProxies.*
compute.compute.compute.compute.compute.targetSslProxies.getcompute.targetSslProxies.listcompute.compute.compute.compute.compute.compute.compute.compute.compute.targetSslProxies.usecompute.targetTcpProxies.*
compute.compute.compute.compute.compute.targetTcpProxies.getcompute.targetTcpProxies.listcompute.compute.compute.compute.targetTcpProxies.usecompute.targetVpnGateways.*
compute.compute.compute.compute.compute.targetVpnGateways.getcompute.targetVpnGateways.listcompute.compute.compute.compute.targetVpnGateways.usecompute.urlMaps.*
compute.urlMaps.createcompute.compute.urlMaps.deletecompute.compute.urlMaps.getcompute.compute.urlMaps.listcompute.compute.compute.urlMaps.updatecompute.urlMaps.usecompute.urlMaps.validatecompute.vpnGateways.*
compute.vpnGateways.createcompute.compute.vpnGateways.deletecompute.compute.vpnGateways.getcompute.vpnGateways.listcompute.compute.compute.vpnGateways.setLabelscompute.vpnGateways.usecompute.vpnTunnels.*
compute.vpnTunnels.createcompute.compute.vpnTunnels.deletecompute.compute.vpnTunnels.getcompute.vpnTunnels.listcompute.compute.compute.vpnTunnels.setLabelscompute.wireGroups.*
compute.wireGroups.createcompute.wireGroups.deletecompute.wireGroups.getcompute.wireGroups.listcompute.wireGroups.updatecompute.zoneOperations.getcompute.zoneOperations.listcompute.zones.*
compute.zones.getcompute.zones.listdataflow.jobs.*
dataflow.jobs.canceldataflow.jobs.createdataflow.jobs.getdataflow.jobs.listdataflow.jobs.snapshotdataflow.jobs.updateContentsdataflow.messages.listdataflow.metrics.getdataflow.snapshots.*
dataflow.snapshots.deletedataflow.snapshots.getdataflow.snapshots.listdataform.*
dataform.commentThreads.createdataform.commentThreads.deletedataform.commentThreads.getdataform.commentThreads.listdataform.commentThreads.updatedataform.comments.createdataform.comments.deletedataform.comments.getdataform.comments.listdataform.comments.updatedataform.dataform.dataform.dataform.dataform.config.getdataform.config.updatedataform.folders.addContentsdataform.folders.createdataform.folders.deletedataform.folders.getdataform.folders.getIamPolicydataform.folders.movedataform.folders.queryContentsdataform.folders.setIamPolicydataform.folders.updatedataform.locations.getdataform.locations.listdataform.operations.canceldataform.operations.deletedataform.operations.getdataform.operations.listdataform.releaseConfigs.createdataform.releaseConfigs.deletedataform.releaseConfigs.getdataform.releaseConfigs.listdataform.releaseConfigs.updatedataform.repositories.commitdataform.dataform.repositories.createdataform.repositories.deletedataform.dataform.dataform.repositories.getdataform.dataform.repositories.listdataform.repositories.movedataform.dataform.repositories.readFiledataform.dataform.dataform.dataform.repositories.updatedataform.teamFolders.createdataform.teamFolders.deletedataform.teamFolders.getdataform.dataform.dataform.teamFolders.updatedataform.dataform.dataform.workflowConfigs.getdataform.workflowConfigs.listdataform.dataform.dataform.dataform.dataform.dataform.dataform.dataform.workspaces.commitdataform.workspaces.createdataform.workspaces.deletedataform.dataform.dataform.dataform.workspaces.getdataform.dataform.dataform.workspaces.listdataform.dataform.dataform.workspaces.moveFiledataform.workspaces.pulldataform.workspaces.pushdataform.dataform.workspaces.readFiledataform.dataform.workspaces.removeFiledataform.workspaces.resetdataform.dataform.dataform.workspaces.writeFiledataplex.datascans.*
dataplex.datascans.createdataplex.datascans.deletedataplex.datascans.getdataplex.datascans.getDatadataplex.dataplex.datascans.listdataplex.datascans.rundataplex.dataplex.datascans.updatedataplex.operations.getdataplex.operations.listdataplex.projects.searchdns.firebase.projects.getiam.serviceAccounts.actAsiam.serviceAccounts.getiam.iam.iam.serviceAccounts.listiam.serviceAccounts.signBlobiam.serviceAccounts.signJwtlogging.buckets.createlogging.logging.buckets.deletelogging.logging.buckets.getlogging.buckets.listlogging.logging.logging.buckets.undeletelogging.buckets.updatelogging.exclusions.*
logging.exclusions.createlogging.exclusions.deletelogging.exclusions.getlogging.exclusions.listlogging.exclusions.updatelogging.links.*
logging.links.createlogging.links.deletelogging.links.getlogging.links.listlogging.locations.*
logging.locations.getlogging.locations.listlogging.logEntries.createlogging.logEntries.routelogging.logMetrics.*
logging.logMetrics.createlogging.logMetrics.deletelogging.logMetrics.getlogging.logMetrics.listlogging.logMetrics.updatelogging.logScopes.*
logging.logScopes.createlogging.logScopes.deletelogging.logScopes.getlogging.logScopes.listlogging.logScopes.updatelogging.logServiceIndexes.listlogging.logServices.listlogging.logs.listlogging.notificationRules.*
logging.logging.logging.notificationRules.getlogging.notificationRules.listlogging.logging.operations.*
logging.operations.cancellogging.operations.getlogging.operations.listlogging.settings.*
logging.settings.getlogging.settings.updatelogging.sinks.*
logging.sinks.createlogging.sinks.deletelogging.sinks.getlogging.sinks.listlogging.sinks.updatelogging.sqlAlerts.*
logging.sqlAlerts.createlogging.sqlAlerts.updatelogging.views.createlogging.views.deletelogging.views.getlogging.views.getIamPolicylogging.views.listlogging.views.updatemonitoring.alertPolicies.getmonitoring.alertPolicies.listmonitoring.monitoring.monitoring.alerts.*
monitoring.alerts.getmonitoring.alerts.listmonitoring.dashboards.getmonitoring.dashboards.listmonitoring.monitoring.monitoring.groups.getmonitoring.groups.listmonitoring.monitoring.monitoring.monitoring.
monitoring.monitoring.monitoring.
monitoring.monitoring.monitoring.monitoring.monitoring.services.getmonitoring.services.listmonitoring.slos.getmonitoring.slos.listmonitoring.snoozes.getmonitoring.snoozes.listmonitoring.timeSeries.*
monitoring.timeSeries.createmonitoring.timeSeries.listmonitoring.monitoring.networkconnectivity.
networkconnectivity.networkconnectivity.networkconnectivity.networkconnectivity.networkconnectivity.networkconnectivity.networkconnectivity.networkconnectivity.
networkconnectivity.networkconnectivity.networkconnectivity.
networkconnectivity.networkconnectivity.networkconnectivity.networkconnectivity.networkconnectivity.
networkconnectivity.networkconnectivity.networkconnectivity.networkconnectivity.networkconnectivity.networkconnectivity.networkconnectivity.
networkconnectivity.networkconnectivity.networkconnectivity.networkconnectivity.networkconnectivity.
networkconnectivity.networkconnectivity.networkconnectivity.networkconnectivity.networkconnectivity.networkconnectivity.networkconnectivity.
networkconnectivity.networkconnectivity.networkconnectivity.networkconnectivity.networkconnectivity.networkconnectivity.
networkconnectivity.networkconnectivity.networkconnectivity.networkconnectivity.networkconnectivity.networkmanagement.networkmanagement.networksecurity.
networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.
networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.
networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.
networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.
networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.
networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.
networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.
networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.
networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.locations.*
networksecurity.locations.getnetworksecurity.locations.listnetworksecurity.operations.*
networksecurity.networksecurity.networksecurity.operations.getnetworksecurity.networksecurity.
networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.sacRealms.*
networksecurity.networksecurity.networksecurity.sacRealms.getnetworksecurity.sacRealms.listnetworksecurity.
networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.
networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.
networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.
networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.networksecurity.urlLists.*
networksecurity.networksecurity.networksecurity.urlLists.getnetworksecurity.urlLists.listnetworksecurity.networksecurity.urlLists.usenetworkservices.*
networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.gateways.getnetworkservices.gateways.listnetworkservices.networkservices.gateways.usenetworkservices.networkservices.networkservices.grpcRoutes.getnetworkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.httpRoutes.getnetworkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.locations.getnetworkservices.locations.listnetworkservices.meshes.createnetworkservices.meshes.deletenetworkservices.meshes.getnetworkservices.meshes.listnetworkservices.meshes.updatenetworkservices.meshes.usenetworkservices.networkservices.networkservices.operations.getnetworkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.tcpRoutes.getnetworkservices.tcpRoutes.listnetworkservices.networkservices.networkservices.networkservices.tlsRoutes.getnetworkservices.tlsRoutes.listnetworkservices.networkservices.networkservices.networkservices.networkservices.networkservices.networkservices.observability.scopes.getopsconfigmonitoring.orgpolicy.policy.getpubsub.*
pubsub.pubsub.schemas.attachpubsub.schemas.commitpubsub.schemas.createpubsub.schemas.deletepubsub.schemas.getpubsub.schemas.getIamPolicypubsub.schemas.listpubsub.schemas.listRevisionspubsub.schemas.rollbackpubsub.schemas.setIamPolicypubsub.schemas.validatepubsub.snapshots.createpubsub.pubsub.snapshots.deletepubsub.pubsub.snapshots.getpubsub.snapshots.getIamPolicypubsub.snapshots.listpubsub.pubsub.pubsub.snapshots.seekpubsub.snapshots.setIamPolicypubsub.snapshots.updatepubsub.subscriptions.consumepubsub.subscriptions.createpubsub.pubsub.subscriptions.deletepubsub.pubsub.subscriptions.getpubsub.pubsub.subscriptions.listpubsub.pubsub.pubsub.pubsub.subscriptions.updatepubsub.pubsub.topics.createpubsub.topics.createTagBindingpubsub.topics.deletepubsub.topics.deleteTagBindingpubsub.pubsub.topics.getpubsub.topics.getIamPolicypubsub.topics.listpubsub.pubsub.topics.listTagBindingspubsub.topics.publishpubsub.topics.setIamPolicypubsub.topics.updatepubsub.topics.updateTagrecommender.
recommender.recommender.recommender.recommender.
recommender.recommender.recommender.recommender.
recommender.recommender.recommender.recommender.
recommender.recommender.recommender.recommender.
recommender.recommender.recommender.resourcemanager.resourcemanager.projects.getresourcemanager.projects.listservicedirectory.servicedirectory.servicedirectory.servicedirectory.servicenetworking.servicenetworking.servicenetworking.servicenetworking.servicenetworking.servicenetworking.servicenetworking.servicenetworking.services.getservicenetworking.servicenetworking.serviceusage.serviceusage.serviceusage.serviceusage.groups.*
serviceusage.groups.listserviceusage.serviceusage.serviceusage.quotas.getserviceusage.services.getserviceusage.services.listserviceusage.services.useserviceusage.values.teststackdriver.projects.getstackdriver.storage.anywhereCaches.*
storage.anywhereCaches.createstorage.anywhereCaches.disablestorage.anywhereCaches.getstorage.anywhereCaches.liststorage.anywhereCaches.pausestorage.anywhereCaches.resumestorage.anywhereCaches.updatestorage.bucketOperations.*
storage.storage.bucketOperations.getstorage.bucketOperations.liststorage.buckets.*
storage.buckets.createstorage.storage.buckets.deletestorage.storage.storage.buckets.getstorage.buckets.getIamPolicystorage.buckets.getIpFilterstorage.storage.buckets.liststorage.storage.storage.buckets.relocatestorage.buckets.restorestorage.buckets.setIamPolicystorage.buckets.setIpFilterstorage.buckets.updatestorage.folders.*
storage.folders.createstorage.folders.deletestorage.folders.getstorage.folders.liststorage.folders.renamestorage.intelligenceConfigs.*
storage.storage.storage.managedFolders.*
storage.managedFolders.createstorage.managedFolders.deletestorage.managedFolders.getstorage.storage.managedFolders.liststorage.storage.multipartUploads.*
storage.multipartUploads.abortstorage.storage.multipartUploads.liststorage.storage.objects.*
storage.objects.createstorage.objects.createContextstorage.objects.deletestorage.objects.deleteContextstorage.objects.getstorage.objects.getIamPolicystorage.objects.liststorage.objects.movestorage.storage.objects.restorestorage.objects.setIamPolicystorage.objects.setRetentionstorage.objects.updatestorage.objects.updateContextstoragebatchoperations.*
storagebatchoperations.storagebatchoperations.storagebatchoperations.storagebatchoperations.storagebatchoperations.storagebatchoperations.storagebatchoperations.storagebatchoperations.storagebatchoperations.storagebatchoperations.storagebatchoperations.telemetry.metrics.writetrafficdirector.*
trafficdirector.trafficdirector.
Dataflow Viewer
roles/)
dataflow.jobs.getdataflow.jobs.listdataflow.messages.listdataflow.metrics.getdataflow.snapshots.getdataflow.snapshots.listrecommender.recommender.resourcemanager.projects.getresourcemanager.projects.list
Dataflow Worker
roles/)
autoscaling.autoscaling.sites.writeMetricsautoscaling.sites.writeStatecompute.compute.instances.deletecompute.dataflow.jobs.getdataflow.shuffle.*
dataflow.shuffle.readdataflow.shuffle.writedataflow.streamingWorkItems.*
dataflow.dataflow.dataflow.dataflow.dataflow.dataflow.workItems.*
dataflow.workItems.leasedataflow.workItems.sendMessagedataflow.workItems.updatelogging.logEntries.createlogging.logEntries.routemonitoring.timeSeries.createstorage.buckets.getstorage.objects.createstorage.objects.get
Peran Dataflow Worker (roles/dataflow.worker) memberikan izin yang diperlukan agar akun layanan Compute Engine dapat menjalankan unit kerja untuk pipeline Apache Beam. Peran Dataflow Worker harus ditetapkan ke akun layanan yang dapat meminta dan memperbarui tugas dari layanan Dataflow.
Peran Dataflow Service Agent (roles/dataflow.serviceAgent) digunakan secara eksklusif oleh akun layanan Dataflow. Peran ini memberi akun layanan akses ke resource terkelola di project Google Cloud Anda untuk menjalankan tugas Dataflow. Peran ini otomatis ditetapkan ke akun layanan saat Anda mengaktifkan Dataflow API untuk project Anda dari halaman API di konsol Google Cloud .
Membuat tugas
Untuk membuat tugas, peran roles/dataflow.admin mencakup serangkaian izin minimum yang diperlukan untuk menjalankan dan memeriksa tugas.
Atau, izin berikut diperlukan:
- Peran
roles/dataflow.developeruntuk membuat instance tugas itu sendiri. - Peran
roles/compute.vieweruntuk mengakses informasi jenis mesin dan melihat setelan lainnya. - Peran
roles/storage.objectAdminuntuk memberikan izin melakukan stage file di Cloud Storage.
Contoh penetapan peran
Untuk mengilustrasikan kegunaan berbagai peran Dataflow, pertimbangkan perincian berikut:
- Developer yang membuat dan memeriksa tugas memerlukan peran
roles/iam.serviceAccountUser. - Untuk pengelolaan izin yang lebih kompleks, developer yang berinteraksi dengan tugas Dataflow memerlukan peran
roles/dataflow.developer.- Mereka memerlukan
roles/storage.objectAdminatau peran terkait untuk melakukan stage file yang diperlukan. - Untuk proses debug dan pemeriksaan kuota, mereka memerlukan peran
roles/compute.viewerpada project. - Jika tidak ada penetapan peran lain, peran ini memungkinkan developer membuat dan membatalkan tugas Dataflow, tetapi tidak berinteraksi dengan VM individual atau mengakses layanan Cloud lainnya.
- Mereka memerlukan
- Akun layanan worker memerlukan peran
roles/dataflow.workerdanroles/dataflow.adminuntuk memproses data bagi layanan Dataflow.- Untuk mengakses data tugas, akun layanan worker memerlukan peran lain seperti
roles/storage.objectAdmin. - Untuk menulis ke tabel BigQuery, akun layanan worker memerlukan peran
roles/bigquery.dataEditor. - Untuk membaca dari topik atau langganan Pub/Sub, akun layanan worker memerlukan peran
roles/pubsub.editor.
- Untuk mengakses data tugas, akun layanan worker memerlukan peran lain seperti
- Jika Anda menggunakan VPC Bersama, subnetwork VPC Bersama harus dibagikan ke akun layanan Dataflow dan harus memiliki peran Compute Network User yang ditetapkan ke subnet yang ditentukan.
- Untuk melihat apakah subnetwork VPC Bersama dibagikan dengan akun layanan Dataflow, di konsol Google Cloud , buka halaman VPC Bersama dan cari subnet. Di kolom Dibagikan dengan, Anda dapat melihat apakah subnetwork VPC dibagikan dengan akun layanan Dataflow atau tidak. Untuk mengetahui informasi selengkapnya, lihat Pedoman untuk menentukan parameter subnetwork untuk VPC Bersama.
- Akun layanan Compute Engine project host, akun layanan Dataflow worker project layanan, dan akun layanan yang digunakan untuk mengirimkan tugas harus memiliki peran berikut:
roles/dataflow.adminroles/compute.networkUserroles/storage.objectViewer
Menetapkan peran Dataflow
Saat ini, peran Dataflow hanya dapat ditetapkan di organisasi dan project.
Untuk mengelola peran di level organisasi, lihat Kontrol akses untuk organisasi menggunakan IAM.
Untuk menetapkan peran level project, lihat Memberikan, mengubah, dan mencabut akses ke resource.