usingSystem.Collections.Generic;usingSystem.Linq;usingGoogle.Api.Gax.ResourceNames;usingGoogle.Cloud.Dlp.V2;usingstaticGoogle.Cloud.Dlp.V2.InspectConfig.Types;publicclassInspectStorageWithSCCIntegration{publicstaticDlpJobSendGcsData(stringprojectId,stringgcsPath,LikelihoodminLikelihood=Likelihood.Unlikely,IEnumerable<InfoType>infoTypes=null){// Instantiate the dlp client.vardlp=DlpServiceClient.Create();// Specify the GCS file to be inspected.varstorageConfig=newStorageConfig{CloudStorageOptions=newCloudStorageOptions{FileSet=newCloudStorageOptions.Types.FileSet{Url=gcsPath}}};// Specify the type of info to be inspected and construct the inspect config.varinspectConfig=newInspectConfig{InfoTypes={infoTypes??newInfoType[]{newInfoType{Name="EMAIL_ADDRESS"},newInfoType{Name="PERSON_NAME"},newInfoType{Name="LOCATION"},newInfoType{Name="PHONE_NUMBER"}}},IncludeQuote=true,MinLikelihood=minLikelihood,Limits=newFindingLimits{MaxFindingsPerRequest=100}};// Construct the SCC action which will be performed after inspecting the storage.varactions=newAction[]{newAction{PublishSummaryToCscc=newAction.Types.PublishSummaryToCscc()}};// Construct the inspect job config using storage config, inspect config and action.varinspectJob=newInspectJobConfig{StorageConfig=storageConfig,InspectConfig=inspectConfig,Actions={actions}};// Construct the request.varrequest=newCreateDlpJobRequest{ParentAsLocationName=newLocationName(projectId,"global"),InspectJob=inspectJob};// Call the API.DlpJobresponse=dlp.CreateDlpJob(request);returnresponse;}}

import("context""fmt""io"dlp"cloud.google.com/go/dlp/apiv2""cloud.google.com/go/dlp/apiv2/dlppb")// inspectGCSFileSendToScc inspects sensitive data in a Google Cloud Storage (GCS) file// and sends the inspection results to Google Cloud Security Command Center (SCC) for further analysis.funcinspectGCSFileSendToScc(wio.Writer,projectID,gcsPathstring)error{// projectID := "my-project-id"// gcsPath := "gs://" + "your-bucket-name" + "path/to/file.txt"ctx:=context.Background()// Initialize a client once and reuse it to send multiple requests. Clients// are safe to use across goroutines. When the client is no longer needed,// call the Close method to cleanup its resources.client,err:=dlp.NewClient(ctx)iferr!=nil{returnerr}// Closing the client safely cleans up background resources.deferclient.Close()// Specify the GCS file to be inspected.cloudStorageOptions:=&dlppb.CloudStorageOptions{FileSet:&dlppb.CloudStorageOptions_FileSet{Url:gcsPath,},}// storageCfg represents the configuration for data inspection in various storage types.storageConfig:=&dlppb.StorageConfig{Type:&dlppb.StorageConfig_CloudStorageOptions{CloudStorageOptions:cloudStorageOptions,},}// Specify the type of info the inspection will look for.// See https://cloud.google.com/dlp/docs/infotypes-reference for complete list of info typesinfoTypes:=[]*dlppb.InfoType{{Name:"EMAIL_ADDRESS"},{Name:"PERSON_NAME"},{Name:"LOCATION"},{Name:"PHONE_NUMBER"},}// The minimum likelihood required before returning a match.minLikelihood:=dlppb.Likelihood_UNLIKELY// The maximum number of findings to report (0 = server maximum).findingLimits:=&dlppb.InspectConfig_FindingLimits{MaxFindingsPerItem:100,}inspectConfig:=&dlppb.InspectConfig{InfoTypes:infoTypes,MinLikelihood:minLikelihood,Limits:findingLimits,IncludeQuote:true,}// Specify the action that is triggered when the job completes.action:=&dlppb.Action{Action:&dlppb.Action_PublishSummaryToCscc_{PublishSummaryToCscc:&dlppb.Action_PublishSummaryToCscc{},},}// Configure the inspection job we want the service to perform.inspectJobConfig:=&dlppb.InspectJobConfig{StorageConfig:storageConfig,InspectConfig:inspectConfig,Actions:[]*dlppb.Action{action,},}// Create the request for the job configured above.req:=&dlppb.CreateDlpJobRequest{Parent:fmt.Sprintf("projects/%s/locations/global",projectID),Job:&dlppb.CreateDlpJobRequest_InspectJob{InspectJob:inspectJobConfig,},}// Send the request.resp,err:=client.CreateDlpJob(ctx,req)iferr!=nil{returnerr}// Print the result.fmt.Fprintf(w,"Job created successfully: %v",resp.Name)returnnil}

importcom.google.cloud.dlp.v2.DlpServiceClient;importcom.google.privacy.dlp.v2.Action;importcom.google.privacy.dlp.v2.CloudStorageOptions;importcom.google.privacy.dlp.v2.CreateDlpJobRequest;importcom.google.privacy.dlp.v2.DlpJob;importcom.google.privacy.dlp.v2.InfoType;importcom.google.privacy.dlp.v2.InfoTypeStats;importcom.google.privacy.dlp.v2.InspectConfig;importcom.google.privacy.dlp.v2.InspectDataSourceDetails;importcom.google.privacy.dlp.v2.InspectJobConfig;importcom.google.privacy.dlp.v2.Likelihood;importcom.google.privacy.dlp.v2.LocationName;importcom.google.privacy.dlp.v2.StorageConfig;importjava.io.IOException;importjava.util.List;importjava.util.concurrent.TimeUnit;importjava.util.stream.Collectors;importjava.util.stream.Stream;publicclassInspectGcsFileSendToScc{privatestaticfinalintTIMEOUT_MINUTES=15;publicstaticvoidmain(String[]args)throwsException{// TODO(developer): Replace these variables before running the sample.// The Google Cloud project id to use as a parent resource.StringprojectId="your-project-id";// The name of the file in the Google Cloud Storage bucket.StringgcsPath="gs://"+"your-bucket-name"+"path/to/file.txt";createJobSendToScc(projectId,gcsPath);}// Creates a DLP Job to scan the sample data stored in a Cloud Storage and save its scan results// to Security Command Center.publicstaticvoidcreateJobSendToScc(StringprojectId,StringgcsPath)throwsIOException,InterruptedException{// Initialize client that will be used to send requests. This client only needs to be created// once, and can be reused for multiple requests. After completing all of your requests, call// the "close" method on the client to safely clean up any remaining background resources.try(DlpServiceClientdlpServiceClient=DlpServiceClient.create()){// Specify the GCS file to be inspected.CloudStorageOptionscloudStorageOptions=CloudStorageOptions.newBuilder().setFileSet(CloudStorageOptions.FileSet.newBuilder().setUrl(gcsPath)).build();StorageConfigstorageConfig=StorageConfig.newBuilder().setCloudStorageOptions(cloudStorageOptions).build();// Specify the type of info the inspection will look for.// See https://cloud.google.com/dlp/docs/infotypes-reference for complete list of info typesList<InfoType>infoTypes=Stream.of("EMAIL_ADDRESS","PERSON_NAME","LOCATION","PHONE_NUMBER").map(it->InfoType.newBuilder().setName(it).build()).collect(Collectors.toList());// The minimum likelihood required before returning a match.// See: https://cloud.google.com/dlp/docs/likelihoodLikelihoodminLikelihood=Likelihood.UNLIKELY;// The maximum number of findings to report (0 = server maximum)InspectConfig.FindingLimitsfindingLimits=InspectConfig.FindingLimits.newBuilder().setMaxFindingsPerItem(100).build();InspectConfiginspectConfig=InspectConfig.newBuilder().addAllInfoTypes(infoTypes).setIncludeQuote(true).setMinLikelihood(minLikelihood).setLimits(findingLimits).build();// Specify the action that is triggered when the job completes.Action.PublishSummaryToCsccpublishSummaryToCscc=Action.PublishSummaryToCscc.getDefaultInstance();Actionaction=Action.newBuilder().setPublishSummaryToCscc(publishSummaryToCscc).build();// Configure the inspection job we want the service to perform.InspectJobConfiginspectJobConfig=InspectJobConfig.newBuilder().setInspectConfig(inspectConfig).setStorageConfig(storageConfig).addActions(action).build();// Construct the job creation request to be sent by the client.CreateDlpJobRequestcreateDlpJobRequest=CreateDlpJobRequest.newBuilder().setParent(LocationName.of(projectId,"global").toString()).setInspectJob(inspectJobConfig).build();// Send the job creation request and process the response.DlpJobresponse=dlpServiceClient.createDlpJob(createDlpJobRequest);// Get the current time.longstartTime=System.currentTimeMillis();// Check if the job state is DONE.while(response.getState()!=DlpJob.JobState.DONE){// Sleep for 30 second.Thread.sleep(30000);// Get the updated job status.response=dlpServiceClient.getDlpJob(response.getName());// Check if the timeout duration has exceeded.longelapsedTime=System.currentTimeMillis()-startTime;if(TimeUnit.MILLISECONDS.toMinutes(elapsedTime)>=TIMEOUT_MINUTES){System.out.printf("Job did not complete within %d minutes.%n",TIMEOUT_MINUTES);break;}}// Print the results.System.out.println("Job status: "+response.getState());System.out.println("Job name: "+response.getName());InspectDataSourceDetails.Resultresult=response.getInspectDetails().getResult();System.out.println("Findings: ");for(InfoTypeStatsinfoTypeStat:result.getInfoTypeStatsList()){System.out.print("\tInfo type: "+infoTypeStat.getInfoType().getName());System.out.println("\tCount: "+infoTypeStat.getCount());}}}}

// Imports the Google Cloud Data Loss Prevention libraryconstDLP=require('@google-cloud/dlp');// Instantiates a clientconstdlpClient=newDLP.DlpServiceClient();// The project ID to run the API call under// const projectId = 'your-project-id';// The name of the file in the bucket// const gcsPath = 'gcs-file-path';asyncfunctioninspectGCSSendToScc(){// Specify the storage configuration object with GCS URL.conststorageConfig={cloudStorageOptions:{fileSet:{url:gcsPath,},},};// Construct the info types to look for in the GCS file.constinfoTypes=[{name:'EMAIL_ADDRESS'},{name:'PERSON_NAME'},{name:'LOCATION'},{name:'PHONE_NUMBER'},];// Construct the inspection configuration.constinspectConfig={infoTypes,minLikelihood:DLP.protos.google.privacy.dlp.v2.Likelihood.UNLIKELY,limits:{maxFindingsPerItem:100,},};// Specify the action that is triggered when the job completes.constaction={publishSummaryToCscc:{},};// Configure the inspection job we want the service to perform.constjobConfig={inspectConfig,storageConfig,actions:[action],};// Construct the job creation request to be sent by the client.constrequest={parent:`projects/${projectId}/locations/global`,inspectJob:jobConfig,};// Send the job creation request and process the response.const[jobsResponse]=awaitdlpClient.createDlpJob(request);constjobName=jobsResponse.name;// Waiting for a maximum of 15 minutes for the job to get complete.letjob;letnumOfAttempts=30;while(numOfAttempts >0){// Fetch DLP Job status[job]=awaitdlpClient.getDlpJob({name:jobName});// Check if the job has completed.if(job.state==='DONE'){break;}if(job.state==='FAILED'){console.log('Job Failed, Please check the configuration.');return;}// Sleep for a short duration before checking the job status again.awaitnewPromise(resolve=>{setTimeout(()=>resolve(),30000);});numOfAttempts-=1;}// Print out the results.constinfoTypeStats=job.inspectDetails.result.infoTypeStats;if(infoTypeStats.length >0){infoTypeStats.forEach(infoTypeStat=>{console.log(`Found${infoTypeStat.count} instance(s) of infoType${infoTypeStat.infoType.name}.`);});}else{console.log('No findings.');}}awaitinspectGCSSendToScc();

use Google\Cloud\Dlp\V2\Action;use Google\Cloud\Dlp\V2\Action\PublishSummaryToCscc;use Google\Cloud\Dlp\V2\Client\DlpServiceClient;use Google\Cloud\Dlp\V2\CloudStorageOptions;use Google\Cloud\Dlp\V2\CloudStorageOptions\FileSet;use Google\Cloud\Dlp\V2\CreateDlpJobRequest;use Google\Cloud\Dlp\V2\DlpJob\JobState;use Google\Cloud\Dlp\V2\GetDlpJobRequest;use Google\Cloud\Dlp\V2\InfoType;use Google\Cloud\Dlp\V2\InspectConfig;use Google\Cloud\Dlp\V2\InspectConfig\FindingLimits;use Google\Cloud\Dlp\V2\InspectJobConfig;use Google\Cloud\Dlp\V2\Likelihood;use Google\Cloud\Dlp\V2\StorageConfig;/** * (GCS) Send Cloud DLP scan results to Security Command Center. * Using Cloud Data Loss Prevention to scan specific Google Cloud resources and send data to Security Command Center. * * @param string $callingProjectId  The project ID to run the API call under. * @param string $gcsUri            GCS file to be inspected. */function inspect_gcs_send_to_scc(    // TODO(developer): Replace sample parameters before running the code.    string $callingProjectId,    string $gcsUri = 'gs://GOOGLE_STORAGE_BUCKET_NAME/dlp_sample.csv'): void {    // Instantiate a client.    $dlp = new DlpServiceClient();    // Construct the items to be inspected.    $cloudStorageOptions = (new CloudStorageOptions())        ->setFileSet((new FileSet())            ->setUrl($gcsUri));    $storageConfig = (new StorageConfig())        ->setCloudStorageOptions(($cloudStorageOptions));    // Specify the type of info the inspection will look for.    $infoTypes = [        (new InfoType())->setName('EMAIL_ADDRESS'),        (new InfoType())->setName('PERSON_NAME'),        (new InfoType())->setName('LOCATION'),        (new InfoType())->setName('PHONE_NUMBER')    ];    // Specify how the content should be inspected.    $inspectConfig = (new InspectConfig())        ->setMinLikelihood(likelihood::UNLIKELY)        ->setLimits((new FindingLimits())            ->setMaxFindingsPerRequest(100))        ->setInfoTypes($infoTypes)        ->setIncludeQuote(true);    // Specify the action that is triggered when the job completes.    $action = (new Action())        ->setPublishSummaryToCscc(new PublishSummaryToCscc());    // Construct inspect job config to run.    $inspectJobConfig = (new InspectJobConfig())        ->setInspectConfig($inspectConfig)        ->setStorageConfig($storageConfig)        ->setActions([$action]);    // Send the job creation request and process the response.    $parent = "projects/$callingProjectId/locations/global";    $createDlpJobRequest = (new CreateDlpJobRequest())        ->setParent($parent)        ->setInspectJob($inspectJobConfig);    $job = $dlp->createDlpJob($createDlpJobRequest);    $numOfAttempts = 10;    do {        printf('Waiting for job to complete' . PHP_EOL);        sleep(10);        $getDlpJobRequest = (new GetDlpJobRequest())            ->setName($job->getName());        $job = $dlp->getDlpJob($getDlpJobRequest);        if ($job->getState() == JobState::DONE) {            break;        }        $numOfAttempts--;    } while ($numOfAttempts > 0);    // Print finding counts.    printf('Job %s status: %s' . PHP_EOL, $job->getName(), JobState::name($job->getState()));    switch ($job->getState()) {        case JobState::DONE:            $infoTypeStats = $job->getInspectDetails()->getResult()->getInfoTypeStats();            if (count($infoTypeStats) === 0) {                printf('No findings.' . PHP_EOL);            } else {                foreach ($infoTypeStats as $infoTypeStat) {                    printf(                        '  Found %s instance(s) of infoType %s' . PHP_EOL,                        $infoTypeStat->getCount(),                        $infoTypeStat->getInfoType()->getName()                    );                }            }            break;        case JobState::FAILED:            printf('Job %s had errors:' . PHP_EOL, $job->getName());            $errors = $job->getErrors();            foreach ($errors as $error) {                var_dump($error->getDetails());            }            break;        case JobState::PENDING:            printf('Job has not completed. Consider a longer timeout or an asynchronous execution model' . PHP_EOL);            break;        default:            printf('Unexpected job state. Most likely, the job is either running or has not yet started.');    }}

importtimefromtypingimportListimportgoogle.cloud.dlpdefinspect_gcs_send_to_scc(project:str,bucket:str,info_types:List[str],max_findings:int=100,)->None:"""    Uses the Data Loss Prevention API to inspect Google Cloud Storage    data and send the results to Google Security Command Center.    Args:        project: The Google Cloud project id to use as a parent resource.        bucket: The name of the GCS bucket containing the file, as a string.        info_types: A list of strings representing infoTypes to inspect for.            A full list of infoType categories can be fetched from the API.        max_findings: The maximum number of findings to report; 0 = no maximum.    """# Instantiate a client.dlp=google.cloud.dlp_v2.DlpServiceClient()# Prepare info_types by converting the list of strings into a list of# dictionaries.info_types=[{"name":info_type}forinfo_typeininfo_types]# Construct the configuration dictionary.inspect_config={"info_types":info_types,"min_likelihood":google.cloud.dlp_v2.Likelihood.UNLIKELY,"limits":{"max_findings_per_request":max_findings},"include_quote":True,}# Construct a cloud_storage_options dictionary with the bucket's URL.url=f"gs://{bucket}"storage_config={"cloud_storage_options":{"file_set":{"url":url}}}# Tell the API where to send a notification when the job is complete.actions=[{"publish_summary_to_cscc":{}}]# Construct the job definition.job={"inspect_config":inspect_config,"storage_config":storage_config,"actions":actions,}# Convert the project id into a full resource id.parent=f"projects/{project}"# Call the API.response=dlp.create_dlp_job(request={"parent":parent,"inspect_job":job,})print(f"Inspection Job started :{response.name}")job_name=response.name# Waiting for maximum 15 minutes for the job to get complete.no_of_attempts=30whileno_of_attempts >0:# Get the DLP job status.job=dlp.get_dlp_job(request={"name":job_name})# Check if the job has completed.ifjob.state==google.cloud.dlp_v2.DlpJob.JobState.DONE:breakelifjob.state==google.cloud.dlp_v2.DlpJob.JobState.FAILED:print("Job Failed, Please check the configuration.")return# Sleep for a short duration before checking the job status again.time.sleep(30)no_of_attempts-=1# Print out the results.print(f"Job name:{job.name}")result=job.inspect_details.resultprint("Processed Bytes: ",result.processed_bytes)ifresult.info_type_stats:forstatsinresult.info_type_stats:print(f"Info type:{stats.info_type.name}")print(f"Count:{stats.count}")else:print("No findings.")

usingSystem.Collections.Generic;usingGoogle.Api.Gax.ResourceNames;usingGoogle.Cloud.Dlp.V2;usingstaticGoogle.Cloud.Dlp.V2.InspectConfig.Types;publicclassInspectBigQueryWithSCCIntegration{publicstaticDlpJobSendBigQueryData(stringprojectId,LikelihoodminLikelihood=Likelihood.Unlikely,IEnumerable<InfoType>infoTypes=null){// Instantiate the dlp client.vardlp=DlpServiceClient.Create();// Construct the storage config by providing the table to be inspected.varstorageConfig=newStorageConfig{BigQueryOptions=newBigQueryOptions{TableReference=newBigQueryTable{ProjectId="bigquery-public-data",DatasetId="usa_names",TableId="usa_1910_current",}}};// Construct the inspect config by specifying the type of info to be inspected.varinspectConfig=newInspectConfig{InfoTypes={infoTypes??newInfoType[]{newInfoType{Name="EMAIL_ADDRESS"},newInfoType{Name="PERSON_NAME"}}},IncludeQuote=true,MinLikelihood=minLikelihood,Limits=newFindingLimits{MaxFindingsPerRequest=100}};// Construct the SCC action which will be performed after inspecting the source.varactions=newAction[]{newAction{PublishSummaryToCscc=newAction.Types.PublishSummaryToCscc()}};// Construct the inspect job config using storage config, inspect config and action.varinspectJob=newInspectJobConfig{StorageConfig=storageConfig,InspectConfig=inspectConfig,Actions={actions}};// Construct the request.varrequest=newCreateDlpJobRequest{ParentAsLocationName=newLocationName(projectId,"global"),InspectJob=inspectJob};// Call the API.DlpJobresponse=dlp.CreateDlpJob(request);System.Console.WriteLine($"Job created successfully. Job name: {response.Name}");returnresponse;}}

import("context""fmt""io"dlp"cloud.google.com/go/dlp/apiv2""cloud.google.com/go/dlp/apiv2/dlppb")// inspectBigQuerySendToScc configures the inspection job that instructs Cloud DLP to scan data stored in BigQuery,// and also instructs Cloud DLP to save its scan results to Security Command Center.funcinspectBigQuerySendToScc(wio.Writer,projectID,bigQueryDatasetId,bigQueryTableIdstring)error{// projectID := "my-project-id"// bigQueryDatasetId := "your-project-bigquery-dataset"// bigQueryTableId := "your-project-bigquery_table"ctx:=context.Background()// Initialize a client once and reuse it to send multiple requests. Clients// are safe to use across goroutines. When the client is no longer needed,// call the Close method to cleanup its resources.client,err:=dlp.NewClient(ctx)iferr!=nil{returnerr}// Closing the client safely cleans up background resources.deferclient.Close()// Specify the BigQuery table to be inspected.tableReference:=&dlppb.BigQueryTable{ProjectId:projectID,DatasetId:bigQueryDatasetId,TableId:bigQueryTableId,}bigQueryOptions:=&dlppb.BigQueryOptions{TableReference:tableReference,}// Specify the type of storage that you have configured.storageConfig:=&dlppb.StorageConfig{Type:&dlppb.StorageConfig_BigQueryOptions{BigQueryOptions:bigQueryOptions,},}// Specify the type of info the inspection will look for.// See https://cloud.google.com/dlp/docs/infotypes-reference for complete list of info types.infoTypes:=[]*dlppb.InfoType{{Name:"EMAIL_ADDRESS"},{Name:"PERSON_NAME"},{Name:"LOCATION"},{Name:"PHONE_NUMBER"},}// The minimum likelihood required before returning a match.minLikelihood:=dlppb.Likelihood_UNLIKELY// The maximum number of findings to report (0 = server maximum).findingLimits:=&dlppb.InspectConfig_FindingLimits{MaxFindingsPerItem:100,}// Specify how the content should be inspected.inspectConfig:=&dlppb.InspectConfig{InfoTypes:infoTypes,MinLikelihood:minLikelihood,Limits:findingLimits,IncludeQuote:true,}// Specify the action that is triggered when the job completes.action:=&dlppb.Action{Action:&dlppb.Action_PublishSummaryToCscc_{PublishSummaryToCscc:&dlppb.Action_PublishSummaryToCscc{},},}// Configure the inspection job we want the service to perform.inspectJobConfig:=&dlppb.InspectJobConfig{StorageConfig:storageConfig,InspectConfig:inspectConfig,Actions:[]*dlppb.Action{action,},}// Create the request for the job configured above.req:=&dlppb.CreateDlpJobRequest{Parent:fmt.Sprintf("projects/%s/locations/global",projectID),Job:&dlppb.CreateDlpJobRequest_InspectJob{InspectJob:inspectJobConfig,},}// Send the request.resp,err:=client.CreateDlpJob(ctx,req)iferr!=nil{returnerr}// Print the resultfmt.Fprintf(w,"Job created successfully: %v",resp.Name)returnnil}

importcom.google.cloud.dlp.v2.DlpServiceClient;importcom.google.privacy.dlp.v2.Action;importcom.google.privacy.dlp.v2.BigQueryOptions;importcom.google.privacy.dlp.v2.BigQueryTable;importcom.google.privacy.dlp.v2.CreateDlpJobRequest;importcom.google.privacy.dlp.v2.DlpJob;importcom.google.privacy.dlp.v2.InfoType;importcom.google.privacy.dlp.v2.InfoTypeStats;importcom.google.privacy.dlp.v2.InspectConfig;importcom.google.privacy.dlp.v2.InspectDataSourceDetails;importcom.google.privacy.dlp.v2.InspectJobConfig;importcom.google.privacy.dlp.v2.Likelihood;importcom.google.privacy.dlp.v2.LocationName;importcom.google.privacy.dlp.v2.StorageConfig;importjava.util.List;importjava.util.concurrent.TimeUnit;importjava.util.stream.Collectors;importjava.util.stream.Stream;publicclassInspectBigQuerySendToScc{privatestaticfinalintTIMEOUT_MINUTES=15;publicstaticvoidmain(String[]args)throwsException{// TODO(developer): Replace these variables before running the sample.// The Google Cloud project id to use as a parent resource.StringprojectId="your-project-id";// The BigQuery dataset id to be used and the reference table name to be inspected.StringbigQueryDatasetId="your-project-bigquery-dataset";StringbigQueryTableId="your-project-bigquery_table";inspectBigQuerySendToScc(projectId,bigQueryDatasetId,bigQueryTableId);}// Inspects a BigQuery Table to send data to Security Command Center.publicstaticvoidinspectBigQuerySendToScc(StringprojectId,StringbigQueryDatasetId,StringbigQueryTableId)throwsException{// Initialize client that will be used to send requests. This client only needs to be created// once, and can be reused for multiple requests. After completing all of your requests, call// the "close" method on the client to safely clean up any remaining background resources.try(DlpServiceClientdlpServiceClient=DlpServiceClient.create()){// Specify the BigQuery table to be inspected.BigQueryTabletableReference=BigQueryTable.newBuilder().setProjectId(projectId).setDatasetId(bigQueryDatasetId).setTableId(bigQueryTableId).build();BigQueryOptionsbigQueryOptions=BigQueryOptions.newBuilder().setTableReference(tableReference).build();StorageConfigstorageConfig=StorageConfig.newBuilder().setBigQueryOptions(bigQueryOptions).build();// Specify the type of info the inspection will look for.List<InfoType>infoTypes=Stream.of("EMAIL_ADDRESS","PERSON_NAME","LOCATION","PHONE_NUMBER").map(it->InfoType.newBuilder().setName(it).build()).collect(Collectors.toList());// The minimum likelihood required before returning a match.LikelihoodminLikelihood=Likelihood.UNLIKELY;// The maximum number of findings to report (0 = server maximum)InspectConfig.FindingLimitsfindingLimits=InspectConfig.FindingLimits.newBuilder().setMaxFindingsPerItem(100).build();// Specify how the content should be inspected.InspectConfiginspectConfig=InspectConfig.newBuilder().addAllInfoTypes(infoTypes).setIncludeQuote(true).setMinLikelihood(minLikelihood).setLimits(findingLimits).build();// Specify the action that is triggered when the job completes.Action.PublishSummaryToCsccpublishSummaryToCscc=Action.PublishSummaryToCscc.getDefaultInstance();Actionaction=Action.newBuilder().setPublishSummaryToCscc(publishSummaryToCscc).build();// Configure the inspection job we want the service to perform.InspectJobConfiginspectJobConfig=InspectJobConfig.newBuilder().setInspectConfig(inspectConfig).setStorageConfig(storageConfig).addActions(action).build();// Construct the job creation request to be sent by the client.CreateDlpJobRequestcreateDlpJobRequest=CreateDlpJobRequest.newBuilder().setParent(LocationName.of(projectId,"global").toString()).setInspectJob(inspectJobConfig).build();// Send the job creation request and process the response.DlpJobresponse=dlpServiceClient.createDlpJob(createDlpJobRequest);// Get the current time.longstartTime=System.currentTimeMillis();// Check if the job state is DONE.while(response.getState()!=DlpJob.JobState.DONE){// Sleep for 30 second.Thread.sleep(30000);// Get the updated job status.response=dlpServiceClient.getDlpJob(response.getName());// Check if the timeout duration has exceeded.longelapsedTime=System.currentTimeMillis()-startTime;if(TimeUnit.MILLISECONDS.toMinutes(elapsedTime)>=TIMEOUT_MINUTES){System.out.printf("Job did not complete within %d minutes.%n",TIMEOUT_MINUTES);break;}}// Print the results.System.out.println("Job status: "+response.getState());System.out.println("Job name: "+response.getName());InspectDataSourceDetails.Resultresult=response.getInspectDetails().getResult();System.out.println("Findings: ");for(InfoTypeStatsinfoTypeStat:result.getInfoTypeStatsList()){System.out.print("\tInfo type: "+infoTypeStat.getInfoType().getName());System.out.println("\tCount: "+infoTypeStat.getCount());}}}}

// Imports the Google Cloud Data Loss Prevention libraryconstDLP=require('@google-cloud/dlp');// Instantiates a clientconstdlp=newDLP.DlpServiceClient();// The project ID to run the API call under.// const projectId = "your-project-id";// The project ID the table is stored under// This may or (for public datasets) may not equal the calling project ID// const dataProjectId = 'my-project';// The ID of the dataset to inspect, e.g. 'my_dataset'// const datasetId = 'my_dataset';// The ID of the table to inspect, e.g. 'my_table'// const tableId = 'my_table';asyncfunctioninspectBigQuerySendToScc(){// Specify the storage configuration object with big query table.conststorageItem={bigQueryOptions:{tableReference:{projectId:dataProjectId,datasetId:datasetId,tableId:tableId,},},};// Specify the type of info the inspection will look for.constinfoTypes=[{name:'EMAIL_ADDRESS'},{name:'PERSON_NAME'},{name:'LOCATION'},{name:'PHONE_NUMBER'},];// Construct inspect configuration.constinspectConfig={infoTypes:infoTypes,includeQuote:true,minLikelihood:DLP.protos.google.privacy.dlp.v2.Likelihood.UNLIKELY,limits:{maxFindingsPerItem:100,},};// Specify the action that is triggered when the job completes.constaction={publishSummaryToCscc:{enable:true,},};// Configure the inspection job we want the service to perform.constinspectJobConfig={inspectConfig:inspectConfig,storageConfig:storageItem,actions:[action],};// Construct the job creation request to be sent by the client.constrequest={parent:`projects/${projectId}/locations/global`,inspectJob:inspectJobConfig,};// Send the job creation request and process the response.const[jobsResponse]=awaitdlp.createDlpJob(request);constjobName=jobsResponse.name;// Waiting for a maximum of 15 minutes for the job to get complete.letjob;letnumOfAttempts=30;while(numOfAttempts >0){// Fetch DLP Job status[job]=awaitdlp.getDlpJob({name:jobName});// Check if the job has completed.if(job.state==='DONE'){break;}if(job.state==='FAILED'){console.log('Job Failed, Please check the configuration.');return;}// Sleep for a short duration before checking the job status again.awaitnewPromise(resolve=>{setTimeout(()=>resolve(),30000);});numOfAttempts-=1;}// Print out the results.constinfoTypeStats=job.inspectDetails.result.infoTypeStats;if(infoTypeStats.length >0){infoTypeStats.forEach(infoTypeStat=>{console.log(`  Found${infoTypeStat.count} instance(s) of infoType${infoTypeStat.infoType.name}.`);});}else{console.log('No findings.');}}awaitinspectBigQuerySendToScc();

use Google\Cloud\Dlp\V2\Action;use Google\Cloud\Dlp\V2\Action\PublishSummaryToCscc;use Google\Cloud\Dlp\V2\BigQueryOptions;use Google\Cloud\Dlp\V2\BigQueryTable;use Google\Cloud\Dlp\V2\Client\DlpServiceClient;use Google\Cloud\Dlp\V2\CreateDlpJobRequest;use Google\Cloud\Dlp\V2\DlpJob\JobState;use Google\Cloud\Dlp\V2\GetDlpJobRequest;use Google\Cloud\Dlp\V2\InfoType;use Google\Cloud\Dlp\V2\InspectConfig;use Google\Cloud\Dlp\V2\InspectConfig\FindingLimits;use Google\Cloud\Dlp\V2\InspectJobConfig;use Google\Cloud\Dlp\V2\Likelihood;use Google\Cloud\Dlp\V2\StorageConfig;/** * (BIGQUERY) Send Cloud DLP scan results to Security Command Center. * Using Cloud Data Loss Prevention to scan specific Google Cloud resources and send data to Security Command Center. * * @param string $callingProjectId  The project ID to run the API call under. * @param string $projectId         The ID of the Project. * @param string $datasetId         The ID of the BigQuery Dataset. * @param string $tableId           The ID of the BigQuery Table to be inspected. */function inspect_bigquery_send_to_scc(    // TODO(developer): Replace sample parameters before running the code.    string $callingProjectId,    string $projectId,    string $datasetId,    string $tableId): void {    // Instantiate a client.    $dlp = new DlpServiceClient();    // Construct the items to be inspected.    $bigqueryTable = (new BigQueryTable())        ->setProjectId($projectId)        ->setDatasetId($datasetId)        ->setTableId($tableId);    $bigQueryOptions = (new BigQueryOptions())        ->setTableReference($bigqueryTable);    $storageConfig = (new StorageConfig())        ->setBigQueryOptions(($bigQueryOptions));    // Specify the type of info the inspection will look for.    $infoTypes = [        (new InfoType())->setName('EMAIL_ADDRESS'),        (new InfoType())->setName('PERSON_NAME'),        (new InfoType())->setName('LOCATION'),        (new InfoType())->setName('PHONE_NUMBER')    ];    // Specify how the content should be inspected.    $inspectConfig = (new InspectConfig())        ->setMinLikelihood(likelihood::UNLIKELY)        ->setLimits((new FindingLimits())            ->setMaxFindingsPerRequest(100))        ->setInfoTypes($infoTypes)        ->setIncludeQuote(true);    // Specify the action that is triggered when the job completes.    $action = (new Action())        ->setPublishSummaryToCscc(new PublishSummaryToCscc());    // Configure the inspection job we want the service to perform.    $inspectJobConfig = (new InspectJobConfig())        ->setInspectConfig($inspectConfig)        ->setStorageConfig($storageConfig)        ->setActions([$action]);    // Send the job creation request and process the response.    $parent = "projects/$callingProjectId/locations/global";    $createDlpJobRequest = (new CreateDlpJobRequest())        ->setParent($parent)        ->setInspectJob($inspectJobConfig);    $job = $dlp->createDlpJob($createDlpJobRequest);    $numOfAttempts = 10;    do {        printf('Waiting for job to complete' . PHP_EOL);        sleep(10);        $getDlpJobRequest = (new GetDlpJobRequest())            ->setName($job->getName());        $job = $dlp->getDlpJob($getDlpJobRequest);        if ($job->getState() == JobState::DONE) {            break;        }        $numOfAttempts--;    } while ($numOfAttempts > 0);    // Print finding counts.    printf('Job %s status: %s' . PHP_EOL, $job->getName(), JobState::name($job->getState()));    switch ($job->getState()) {        case JobState::DONE:            $infoTypeStats = $job->getInspectDetails()->getResult()->getInfoTypeStats();            if (count($infoTypeStats) === 0) {                printf('No findings.' . PHP_EOL);            } else {                foreach ($infoTypeStats as $infoTypeStat) {                    printf(                        '  Found %s instance(s) of infoType %s' . PHP_EOL,                        $infoTypeStat->getCount(),                        $infoTypeStat->getInfoType()->getName()                    );                }            }            break;        case JobState::FAILED:            printf('Job %s had errors:' . PHP_EOL, $job->getName());            $errors = $job->getErrors();            foreach ($errors as $error) {                var_dump($error->getDetails());            }            break;        case JobState::PENDING:            printf('Job has not completed. Consider a longer timeout or an asynchronous execution model' . PHP_EOL);            break;        default:            printf('Unexpected job state. Most likely, the job is either running or has not yet started.');    }}

importtimefromtypingimportListimportgoogle.cloud.dlpdefinspect_bigquery_send_to_scc(project:str,info_types:List[str],max_findings:int=100,)->None:"""    Uses the Data Loss Prevention API to inspect public bigquery dataset    and send the results to Google Security Command Center.    Args:        project: The Google Cloud project id to use as a parent resource.        info_types: A list of strings representing infoTypes to inspect for.            A full list of infoType categories can be fetched from the API.        max_findings: The maximum number of findings to report; 0 = no maximum    """# Instantiate a client.dlp=google.cloud.dlp_v2.DlpServiceClient()# Prepare info_types by converting the list of strings into a list of# dictionaries.info_types=[{"name":info_type}forinfo_typeininfo_types]# Construct the configuration dictionary.inspect_config={"info_types":info_types,"min_likelihood":google.cloud.dlp_v2.Likelihood.UNLIKELY,"limits":{"max_findings_per_request":max_findings},"include_quote":True,}# Construct a Cloud Storage Options dictionary with the big query options.storage_config={"big_query_options":{"table_reference":{"project_id":"bigquery-public-data","dataset_id":"usa_names","table_id":"usa_1910_current",}}}# Tell the API where to send a notification when the job is complete.actions=[{"publish_summary_to_cscc":{}}]# Construct the job definition.job={"inspect_config":inspect_config,"storage_config":storage_config,"actions":actions,}# Convert the project id into a full resource id.parent=f"projects/{project}"# Call the API.response=dlp.create_dlp_job(request={"parent":parent,"inspect_job":job,})print(f"Inspection Job started :{response.name}")job_name=response.name# Waiting for a maximum of 15 minutes for the job to get complete.no_of_attempts=30whileno_of_attempts >0:# Get the DLP job status.job=dlp.get_dlp_job(request={"name":job_name})# Check if the job has completed.ifjob.state==google.cloud.dlp_v2.DlpJob.JobState.DONE:breakifjob.state==google.cloud.dlp_v2.DlpJob.JobState.FAILED:print("Job Failed, Please check the configuration.")return# Sleep for a short duration before checking the job status again.time.sleep(30)no_of_attempts-=1# Print out the results.print(f"Job name:{job.name}")result=job.inspect_details.resultifresult.info_type_stats:forstatsinresult.info_type_stats:print(f"Info type:{stats.info_type.name}")print(f"Count:{stats.count}")else:print("No findings.")

usingSystem.Collections.Generic;usingSystem.Linq;usingGoogle.Api.Gax.ResourceNames;usingGoogle.Cloud.Dlp.V2;usingstaticGoogle.Cloud.Dlp.V2.InspectConfig.Types;publicclassInspectDataStoreJobWithSCCIntegration{publicstaticDlpJobSendInspectDatastoreToSCC(stringprojectId,stringkindName,stringnamespaceId,LikelihoodminLikelihood=Likelihood.Unlikely,IEnumerable<InfoType>infoTypes=null){// Instantiate the dlp client.vardlp=DlpServiceClient.Create();// Specify the Datastore entity to be inspected and construct the storage// config. The NamespaceId is to be used for partition entity and the datastore kind defining// a data set.varstorageConfig=newStorageConfig{DatastoreOptions=newDatastoreOptions{Kind=newKindExpression{Name=kindName},PartitionId=newPartitionId{NamespaceId=namespaceId,ProjectId=projectId}}};// Specify the type of info to be inspected and construct the inspect config.varinspectConfig=newInspectConfig{InfoTypes={infoTypes??newInfoType[]{newInfoType{Name="EMAIL_ADDRESS"},newInfoType{Name="PERSON_NAME"},newInfoType{Name="LOCATION"},newInfoType{Name="PHONE_NUMBER"}}},IncludeQuote=true,MinLikelihood=minLikelihood,Limits=newFindingLimits{MaxFindingsPerRequest=100}};// Construct the SCC action which will be performed after inspecting the datastore.varactions=newAction[]{newAction{PublishSummaryToCscc=newAction.Types.PublishSummaryToCscc()}};// Construct the inspect job config using storage config, inspect config and action.varinspectJob=newInspectJobConfig{StorageConfig=storageConfig,InspectConfig=inspectConfig,Actions={actions}};// Construct the request.varrequest=newCreateDlpJobRequest{ParentAsLocationName=newLocationName(projectId,"global"),InspectJob=inspectJob};// Call the API.DlpJobresponse=dlp.CreateDlpJob(request);returnresponse;}}

import("context""fmt""io"dlp"cloud.google.com/go/dlp/apiv2""cloud.google.com/go/dlp/apiv2/dlppb")// inspectDataStoreSendToScc inspects sensitive data in a Datastore// and sends the results to Google Cloud Security Command Center (SCC).funcinspectDataStoreSendToScc(wio.Writer,projectID,datastoreNamespace,datastoreKindstring)error{// projectID := "my-project-id"// datastoreNamespace := "your-datastore-namespace"// datastoreKind := "your-datastore-kind"ctx:=context.Background()// Initialize a client once and reuse it to send multiple requests. Clients// are safe to use across goroutines. When the client is no longer needed,// call the Close method to cleanup its resources.client,err:=dlp.NewClient(ctx)iferr!=nil{returnerr}// Closing the client safely cleans up background resources.deferclient.Close()// Specify the Datastore entity to be inspected.partitionId:=&dlppb.PartitionId{ProjectId:projectID,NamespaceId:datastoreNamespace,}// kindExpr represents an expression specifying a kind or range of kinds for data inspection in DLP.kindExpression:=&dlppb.KindExpression{Name:datastoreKind,}// Specify datastoreOptions so that It holds the configuration options for inspecting data in// Google Cloud Datastore.datastoreOptions:=&dlppb.DatastoreOptions{PartitionId:partitionId,Kind:kindExpression,}// Specify the storageConfig to represents the configuration settings for inspecting data// in different storage types, such as BigQuery and Cloud Storage.storageConfig:=&dlppb.StorageConfig{Type:&dlppb.StorageConfig_DatastoreOptions{DatastoreOptions:datastoreOptions,},}// Specify the type of info the inspection will look for.// See https://cloud.google.com/dlp/docs/infotypes-reference for complete list of info typesinfoTypes:=[]*dlppb.InfoType{{Name:"EMAIL_ADDRESS"},{Name:"PERSON_NAME"},{Name:"LOCATION"},{Name:"PHONE_NUMBER"},}// The minimum likelihood required before returning a match.minLikelihood:=dlppb.Likelihood_UNLIKELY// The maximum number of findings to report (0 = server maximum).findingLimits:=&dlppb.InspectConfig_FindingLimits{MaxFindingsPerItem:100,}inspectConfig:=&dlppb.InspectConfig{InfoTypes:infoTypes,MinLikelihood:minLikelihood,Limits:findingLimits,IncludeQuote:true,}// Specify the action that is triggered when the job completes.action:=&dlppb.Action{Action:&dlppb.Action_PublishSummaryToCscc_{PublishSummaryToCscc:&dlppb.Action_PublishSummaryToCscc{},},}// Configure the inspection job we want the service to perform.inspectJobConfig:=&dlppb.InspectJobConfig{StorageConfig:storageConfig,InspectConfig:inspectConfig,Actions:[]*dlppb.Action{action,},}// Create the request for the job configured above.req:=&dlppb.CreateDlpJobRequest{Parent:fmt.Sprintf("projects/%s/locations/global",projectID),Job:&dlppb.CreateDlpJobRequest_InspectJob{InspectJob:inspectJobConfig,},}// Send the request.resp,err:=client.CreateDlpJob(ctx,req)iferr!=nil{returnerr}// Print the resultfmt.Fprintf(w,"Job created successfully: %v",resp.Name)returnnil}

importcom.google.cloud.dlp.v2.DlpServiceClient;importcom.google.privacy.dlp.v2.Action;importcom.google.privacy.dlp.v2.CreateDlpJobRequest;importcom.google.privacy.dlp.v2.DatastoreOptions;importcom.google.privacy.dlp.v2.DlpJob;importcom.google.privacy.dlp.v2.InfoType;importcom.google.privacy.dlp.v2.InfoTypeStats;importcom.google.privacy.dlp.v2.InspectConfig;importcom.google.privacy.dlp.v2.InspectDataSourceDetails;importcom.google.privacy.dlp.v2.InspectJobConfig;importcom.google.privacy.dlp.v2.KindExpression;importcom.google.privacy.dlp.v2.Likelihood;importcom.google.privacy.dlp.v2.LocationName;importcom.google.privacy.dlp.v2.PartitionId;importcom.google.privacy.dlp.v2.StorageConfig;importjava.io.IOException;importjava.util.List;importjava.util.concurrent.TimeUnit;importjava.util.stream.Collectors;importjava.util.stream.Stream;publicclassInspectDatastoreSendToScc{privatestaticfinalintTIMEOUT_MINUTES=15;publicstaticvoidmain(String[]args)throwsException{// TODO(developer): Replace these variables before running the sample.// The Google Cloud project id to use as a parent resource.StringprojectId="your-project-id";// The namespace specifier to be used for the partition entity.StringdatastoreNamespace="your-datastore-namespace";// The datastore kind defining a data set.StringdatastoreKind="your-datastore-kind";inspectDatastoreSendToScc(projectId,datastoreNamespace,datastoreKind);}// Creates a DLP Job to scan the sample data stored in a DataStore table and save its scan results// to Security Command Center.publicstaticvoidinspectDatastoreSendToScc(StringprojectId,StringdatastoreNamespace,StringdatastoreKind)throwsIOException,InterruptedException{// Initialize client that will be used to send requests. This client only needs to be created// once, and can be reused for multiple requests. After completing all of your requests, call// the "close" method on the client to safely clean up any remaining background resources.try(DlpServiceClientdlpServiceClient=DlpServiceClient.create()){// Specify the Datastore entity to be inspected.PartitionIdpartitionId=PartitionId.newBuilder().setProjectId(projectId).setNamespaceId(datastoreNamespace).build();KindExpressionkindExpression=KindExpression.newBuilder().setName(datastoreKind).build();DatastoreOptionsdatastoreOptions=DatastoreOptions.newBuilder().setKind(kindExpression).setPartitionId(partitionId).build();StorageConfigstorageConfig=StorageConfig.newBuilder().setDatastoreOptions(datastoreOptions).build();// Specify the type of info the inspection will look for.List<InfoType>infoTypes=Stream.of("EMAIL_ADDRESS","PERSON_NAME","LOCATION","PHONE_NUMBER").map(it->InfoType.newBuilder().setName(it).build()).collect(Collectors.toList());// The minimum likelihood required before returning a match.LikelihoodminLikelihood=Likelihood.UNLIKELY;// The maximum number of findings to report (0 = server maximum)InspectConfig.FindingLimitsfindingLimits=InspectConfig.FindingLimits.newBuilder().setMaxFindingsPerItem(100).build();// Specify how the content should be inspected.InspectConfiginspectConfig=InspectConfig.newBuilder().addAllInfoTypes(infoTypes).setIncludeQuote(true).setMinLikelihood(minLikelihood).setLimits(findingLimits).build();// Specify the action that is triggered when the job completes.Action.PublishSummaryToCsccpublishSummaryToCscc=Action.PublishSummaryToCscc.getDefaultInstance();Actionaction=Action.newBuilder().setPublishSummaryToCscc(publishSummaryToCscc).build();// Configure the inspection job we want the service to perform.InspectJobConfiginspectJobConfig=InspectJobConfig.newBuilder().setInspectConfig(inspectConfig).setStorageConfig(storageConfig).addActions(action).build();// Construct the job creation request to be sent by the client.CreateDlpJobRequestcreateDlpJobRequest=CreateDlpJobRequest.newBuilder().setParent(LocationName.of(projectId,"global").toString()).setInspectJob(inspectJobConfig).build();// Send the job creation request and process the response.DlpJobresponse=dlpServiceClient.createDlpJob(createDlpJobRequest);// Get the current time.longstartTime=System.currentTimeMillis();// Check if the job state is DONE.while(response.getState()!=DlpJob.JobState.DONE){// Sleep for 30 second.Thread.sleep(30000);// Get the updated job status.response=dlpServiceClient.getDlpJob(response.getName());// Check if the timeout duration has exceeded.longelapsedTime=System.currentTimeMillis()-startTime;if(TimeUnit.MILLISECONDS.toMinutes(elapsedTime)>=TIMEOUT_MINUTES){System.out.printf("Job did not complete within %d minutes.%n",TIMEOUT_MINUTES);break;}}// Print the results.System.out.println("Job status: "+response.getState());System.out.println("Job name: "+response.getName());InspectDataSourceDetails.Resultresult=response.getInspectDetails().getResult();System.out.println("Findings: ");for(InfoTypeStatsinfoTypeStat:result.getInfoTypeStatsList()){System.out.print("\tInfo type: "+infoTypeStat.getInfoType().getName());System.out.println("\tCount: "+infoTypeStat.getCount());}}}}

// Imports the Google Cloud Data Loss Prevention libraryconstDLP=require('@google-cloud/dlp');// Instantiates a clientconstdlp=newDLP.DlpServiceClient();// The project ID to run the API call under.// const projectId = "your-project-id";// Datastore namespace// const datastoreNamespace = 'datastore-namespace';// Datastore kind// const datastoreKind = 'datastore-kind';asyncfunctioninspectDatastoreSendToScc(){// Specify the storage configuration object with datastore.conststorageConfig={datastoreOptions:{kind:{name:datastoreKind,},partitionId:{projectId:projectId,namespaceId:datastoreNamespace,},},};// Construct the info types to look for in the datastore.constinfoTypes=[{name:'EMAIL_ADDRESS'},{name:'PERSON_NAME'},{name:'LOCATION'},{name:'PHONE_NUMBER'},];// Construct the inspection configuration.constinspectConfig={infoTypes:infoTypes,minLikelihood:DLP.protos.google.privacy.dlp.v2.Likelihood.UNLIKELY,limits:{maxFindingsPerItem:100,},includeQuote:true,};// Specify the action that is triggered when the job completesconstaction={publishSummaryToCscc:{enable:true},};// Configure the inspection job we want the service to perform.constinspectJobConfig={inspectConfig:inspectConfig,storageConfig:storageConfig,actions:[action],};// Construct the job creation request to be sent by the client.constrequest={parent:`projects/${projectId}/locations/global`,inspectJob:inspectJobConfig,};// Send the job creation request and process the response.const[jobsResponse]=awaitdlp.createDlpJob(request);constjobName=jobsResponse.name;// Waiting for a maximum of 15 minutes for the job to get complete.letjob;letnumOfAttempts=30;while(numOfAttempts >0){// Fetch DLP Job status[job]=awaitdlp.getDlpJob({name:jobName});// Check if the job has completed.if(job.state==='DONE'){break;}if(job.state==='FAILED'){console.log('Job Failed, Please check the configuration.');return;}// Sleep for a short duration before checking the job status again.awaitnewPromise(resolve=>{setTimeout(()=>resolve(),30000);});numOfAttempts-=1;}// Print out the results.constinfoTypeStats=job.inspectDetails.result.infoTypeStats;if(infoTypeStats.length >0){infoTypeStats.forEach(infoTypeStat=>{console.log(`Found${infoTypeStat.count} instance(s) of infoType${infoTypeStat.infoType.name}.`);});}else{console.log('No findings.');}}awaitinspectDatastoreSendToScc();