code: def logstream_policy():
      
      p = Policy(
          Statement=[
              Statement(
                  Effect=Allow,
                  Resource=["*"],
                  Action=[
                      kinesis.CreateStream, kinesis.DescribeStream,
                      Action(kinesis.prefix, "AddTagsToStream"),
                      Action(kinesis.prefix, "PutRecords")
                  ])])
      return p
docs: Policy needed for logspout -> kinesis log streaming.