fluentd.conf

<source>
  @type gcloud_pubsub
  tag pubsub.publish
  project ${GCP_PROJECT_ID}
  topic export-logs-to-logicmonitor-test
  subscription export-logs-to-logicmonitor-test
  max_messages 10000
  return_immediately true
  pull_interval 1
  pull_threads 1
  parse_error_action exception
  enable_rpc true
  rpc_bind 0.0.0.0
  rpc_port 24680
  <parse>
    @type json
  </parse>
</source>


<filter pubsub.publish>
  @type record_transformer
  enable_ruby true
  <record>
    message ${record["textPayload"]}
    mapping ${record.dig("labels", "compute.googleapis.com/resource_name")}
    timestamp ${record["timestamp"]}
    tag ${tag}
  </record>
</filter>

<match pubsub.publish>
    @type lm
    resource_mapping {"mapping": "system.gcp.resourcename"}
    company_name ${LM_COMPANY_NAME}
	access_id ${LM_ACCESS_ID}
    access_key ${LM_ACCESS_KEY}
    log_source "lm-logs-gcp"
    version_id "0.0.1"
      <buffer>
        @type memory
        flush_interval 1s
        chunk_limit_size 5m
      </buffer> 
    debug true
</match>