| 897 | } |
| 898 | |
| 899 | func (s *Session) InsertAlignedRecords(deviceIds []string, measurements [][]string, dataTypes [][]TSDataType, values [][]interface{}, |
| 900 | timestamps []int64, |
| 901 | ) error { |
| 902 | request, err := s.genInsertRecordsReq(deviceIds, measurements, dataTypes, values, timestamps, true) |
| 903 | if err != nil { |
| 904 | return err |
| 905 | } else { |
| 906 | r, err := s.client.InsertRecords(context.Background(), request) |
| 907 | if err != nil && r == nil { |
| 908 | if s.reconnect() { |
| 909 | request.SessionId = s.sessionId |
| 910 | r, err = s.client.InsertRecords(context.Background(), request) |
| 911 | } |
| 912 | } |
| 913 | if err != nil { |
| 914 | return err |
| 915 | } |
| 916 | return VerifySuccess(r) |
| 917 | } |
| 918 | } |
| 919 | |
| 920 | /* |
| 921 | * InsertTablets insert multiple tablets, tablets are independent to each other |